diff --git a/linkstate-edge/kafkanotifier/kafkanotifier.go b/linkstate-edge/kafkanotifier/kafkanotifier.go
index 3b355618..8f26c044 100644
--- a/linkstate-edge/kafkanotifier/kafkanotifier.go
+++ b/linkstate-edge/kafkanotifier/kafkanotifier.go
@@ -173,6 +173,7 @@ func ensureTopic(br *sarama.Broker, timeout time.Duration, topicName string) err
 				},
 			},
 		},
+		Timeout: timeout,
 	}
 
 	for {
diff --git a/topology/kafkanotifier/kafkanotifier.go b/topology/kafkanotifier/kafkanotifier.go
index ff7cb4ea..ab471e02 100644
--- a/topology/kafkanotifier/kafkanotifier.go
+++ b/topology/kafkanotifier/kafkanotifier.go
@@ -239,6 +239,7 @@ func ensureTopic(br *sarama.Broker, timeout time.Duration, topicName string) err
 				},
 			},
 		},
+		Timeout: timeout,
 	}
 
 	for {