From 7f348af3462d507035d15c0a0750a6b08d1833e3 Mon Sep 17 00:00:00 2001
From: severindellsperger <severin.dellsperger@gmail.com>
Date: Wed, 15 Oct 2025 15:21:37 +0200
Subject: [PATCH] add timeout to topic creation request

---
 linkstate-edge/kafkanotifier/kafkanotifier.go | 1 +
 topology/kafkanotifier/kafkanotifier.go       | 1 +
 2 files changed, 2 insertions(+)

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 {