diff --git a/internal/integrations/kafka.go b/internal/integrations/kafka.go
index ebd0b7c..69eef72 100644
--- a/internal/integrations/kafka.go
+++ b/internal/integrations/kafka.go
@@ -16,7 +16,7 @@ func NewKafka(addr, topic string) *Kafka {
 		Addr:                   kafka.TCP(addr),
 		Topic:                  topic,
 		Balancer:               &kafka.RoundRobin{},
-		AllowAutoTopicCreation: true,
+		AllowAutoTopicCreation: false,
 		BatchSize:              100,
 		BatchTimeout:           100 * time.Millisecond,
 	}