Merge pull request #246 from klegul/kafka-publisher-timeout

Add timeout to create topic request in Kafka publisher
sbezverk · Nov 22, 2024 · 3995084 · 3995084
2 parents 216d035 + 4485849
commit 3995084
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/kafka/kafka-publisher.go b/pkg/kafka/kafka-publisher.go
@@ -244,6 +244,7 @@ func ensureTopic(br *sarama.Broker, timeout time.Duration, topicName string, kCo
 				},
 			},
 		},
+		Timeout: timeout,
 	}
 	ticker := time.NewTicker(100 * time.Millisecond)
 	tout := time.NewTimer(timeout)