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 {