modified: pkg/kafka/kafka-publisher.go : for issue "createTopic time…

…outs #210"
sbezverk · Dec 19, 2022 · 5f2f23d · 5f2f23d
1 parent 4a9a9f5
commit 5f2f23d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/kafka/kafka-publisher.go b/pkg/kafka/kafka-publisher.go
@@ -232,7 +232,9 @@ func ensureTopic(br *sarama.Broker, timeout time.Duration, topicName string) err
 				},
 			},
 		},
+		Timeout: timeout,
 	}
+
 	ticker := time.NewTicker(100 * time.Millisecond)
 	tout := time.NewTimer(timeout)
 	for {