From 0dd3e81a40624ed34fc22810f237e0ecfaa89d83 Mon Sep 17 00:00:00 2001 From: Conor Mongey Date: Mon, 21 Oct 2024 13:08:37 +0100 Subject: [PATCH] update topic name for #452 --- kafka/resource_kafka_topic_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/kafka/resource_kafka_topic_test.go b/kafka/resource_kafka_topic_test.go index 459dcb99..69d68211 100644 --- a/kafka/resource_kafka_topic_test.go +++ b/kafka/resource_kafka_topic_test.go @@ -20,7 +20,7 @@ func TestAcc_BasicTopic(t *testing.T) { if err != nil { t.Fatal(err) } - topicName := fmt.Sprintf("syslog-%s", u) + topicName := fmt.Sprintf("prd.syslog-%s", u) bs := testBootstrapServers[0] r.Test(t, r.TestCase{ ProviderFactories: overrideProviderFactory(), @@ -41,7 +41,7 @@ func TestAcc_TopicConfigUpdate(t *testing.T) { if err != nil { t.Fatal(err) } - topicName := fmt.Sprintf("syslog-%s", u) + topicName := fmt.Sprintf("prd.syslog-%s", u) bs := testBootstrapServers[0] r.Test(t, r.TestCase{ @@ -94,7 +94,7 @@ func TestAcc_TopicUpdatePartitions(t *testing.T) { if err != nil { t.Fatal(err) } - topicName := fmt.Sprintf("syslog-%s", u) + topicName := fmt.Sprintf("prd.syslog-%s", u) bs := testBootstrapServers[0] r.Test(t, r.TestCase{ @@ -120,7 +120,7 @@ func TestAcc_TopicAlterReplicationFactor(t *testing.T) { if err != nil { t.Fatal(err) } - topicName := fmt.Sprintf("syslog-%s", u) + topicName := fmt.Sprintf("prd.syslog-%s", u) bs := testBootstrapServers[0] keyEncoder := sarama.StringEncoder("same key -> same partition -> same ordering")