diff --git a/pkg/kafka/kafka-publisher.go b/pkg/kafka/kafka-publisher.go
index dbb8d44..546e86b 100644
--- 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)