Skip to content

Commit

Permalink
update topic name for #452
Browse files Browse the repository at this point in the history
  • Loading branch information
Mongey committed Oct 21, 2024
1 parent 5de3f1e commit 0dd3e81
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions kafka/resource_kafka_topic_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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(),
Expand All @@ -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{
Expand Down Expand Up @@ -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{
Expand All @@ -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")
Expand Down

0 comments on commit 0dd3e81

Please sign in to comment.