From 7568160603e6b5f2e138df3dd2e50c6ac6fca8a6 Mon Sep 17 00:00:00 2001 From: Kamesh Sampath Date: Wed, 6 Dec 2023 08:02:37 +0530 Subject: [PATCH] (fix): allow automatic topic creation --- cmd/server/main.go | 1 + 1 file changed, 1 insertion(+) diff --git a/cmd/server/main.go b/cmd/server/main.go index 0e67029..a6f5f68 100644 --- a/cmd/server/main.go +++ b/cmd/server/main.go @@ -20,6 +20,7 @@ func main() { kgo.ConsumeTopics(config.Topics...), kgo.DefaultProduceTopic(config.DefaultProducerTopic()), kgo.ConsumerGroup(config.ConsumerGroupID), + kgo.AllowAutoTopicCreation(), ) if err != nil {