contrib/IBM/sarama.v1: use an unique topic name for tests (#3075)

DataDog · Jan 10, 2025 · 27624f6 · 27624f6
1 parent d5b23f5
commit 27624f6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/contrib/IBM/sarama.v1/consumer_group_test.go b/contrib/IBM/sarama.v1/consumer_group_test.go
@@ -91,7 +91,7 @@ func TestWrapConsumerGroupHandler(t *testing.T) {
 	s0 := spans[0]
 	assert.Equal(t, "kafka", s0.Tag(ext.ServiceName))
 	assert.Equal(t, "queue", s0.Tag(ext.SpanType))
-	assert.Equal(t, "Produce Topic gotest", s0.Tag(ext.ResourceName))
+	assert.Equal(t, "Produce Topic gotest_ibm_sarama", s0.Tag(ext.ResourceName))
 	assert.Equal(t, "kafka.produce", s0.OperationName())
 	assert.Equal(t, int32(0), s0.Tag(ext.MessagingKafkaPartition))
 	assert.NotNil(t, s0.Tag("offset"))
@@ -104,7 +104,7 @@ func TestWrapConsumerGroupHandler(t *testing.T) {
 	s1 := spans[1]
 	assert.Equal(t, "kafka", s1.Tag(ext.ServiceName))
 	assert.Equal(t, "queue", s1.Tag(ext.SpanType))
-	assert.Equal(t, "Consume Topic gotest", s1.Tag(ext.ResourceName))
+	assert.Equal(t, "Consume Topic gotest_ibm_sarama", s1.Tag(ext.ResourceName))
 	assert.Equal(t, "kafka.consume", s1.OperationName())
 	assert.Equal(t, int32(0), s1.Tag(ext.MessagingKafkaPartition))
 	assert.NotNil(t, s1.Tag("offset"))

diff --git a/contrib/IBM/sarama.v1/sarama_test.go b/contrib/IBM/sarama.v1/sarama_test.go
@@ -23,8 +23,8 @@ import (
 var kafkaBrokers = []string{"localhost:9092", "localhost:9093", "localhost:9094"}
 
 const (
-	testGroupID = "gotest"
-	testTopic   = "gotest"
+	testGroupID = "gotest_ibm_sarama"
+	testTopic   = "gotest_ibm_sarama"
 )
 
 func TestNamingSchema(t *testing.T) {