chore: adding topic for integration test

Trendyol · Aug 31, 2023 · c9345b8 · c9345b8
1 parent c9ea48a
commit c9345b8
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/test/integration/integration_test.go b/test/integration/integration_test.go
@@ -85,6 +85,7 @@ func Test_Should_Consume_Message_Successfully(t *testing.T) {
 
 	// When
 	produceMessages(t, conn, segmentio.Message{
+		Topic: topic,
 		Key:   []byte("1"),
 		Value: []byte(`foo`),
 	})
@@ -129,11 +130,11 @@ func Test_Should_Batch_Consume_Messages_Successfully(t *testing.T) {
 
 	// When
 	produceMessages(t, conn,
-		segmentio.Message{Key: []byte("1"), Value: []byte(`foo1`)},
-		segmentio.Message{Key: []byte("2"), Value: []byte(`foo2`)},
-		segmentio.Message{Key: []byte("3"), Value: []byte(`foo3`)},
-		segmentio.Message{Key: []byte("4"), Value: []byte(`foo4`)},
-		segmentio.Message{Key: []byte("5"), Value: []byte(`foo5`)},
+		segmentio.Message{Topic: topic, Key: []byte("1"), Value: []byte(`foo1`)},
+		segmentio.Message{Topic: topic, Key: []byte("2"), Value: []byte(`foo2`)},
+		segmentio.Message{Topic: topic, Key: []byte("3"), Value: []byte(`foo3`)},
+		segmentio.Message{Topic: topic, Key: []byte("4"), Value: []byte(`foo4`)},
+		segmentio.Message{Topic: topic, Key: []byte("5"), Value: []byte(`foo5`)},
 	)
 
 	// Then
@@ -179,7 +180,7 @@ func Test_Should_Integrate_With_Kafka_Cronsumer_Successfully(t *testing.T) {
 	consumer.Consume()
 
 	// When
-	produceMessages(t, conn, segmentio.Message{Key: []byte("1"), Value: []byte(`foo`)})
+	produceMessages(t, conn, segmentio.Message{Topic: topic, Key: []byte("1"), Value: []byte(`foo`)})
 
 	// Then
 	var expectedOffset int64 = 1