Fixing test for input_kafka

buger · Apr 3, 2024 · df34a93 · df34a93
1 parent a425df7
commit df34a93
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/input_kafka_test.go b/input_kafka_test.go
@@ -16,7 +16,7 @@ func TestInputKafkaRAW(t *testing.T) {
  map[string][]int32{"test": {0}},
  )
 
- input := NewKafkaInput("", &InputKafkaConfig{
+ input := NewKafkaInput("-1", &InputKafkaConfig{
  consumer: consumer,
  Topic: "test",
  UseJSON: false,
@@ -42,7 +42,7 @@ func TestInputKafkaJSON(t *testing.T) {
  map[string][]int32{"test": {0}},
  )
 
- input := NewKafkaInput("", &InputKafkaConfig{
+ input := NewKafkaInput("-1", &InputKafkaConfig{
  consumer: consumer,
  Topic: "test",
  UseJSON: true,