From 5baf5ed7e9686d9da63dfcf0bea90a64fb6ea281 Mon Sep 17 00:00:00 2001
From: Sergey Chubaryan <serghio2@yandex.ru>
Date: Fri, 7 Feb 2025 12:03:46 +0300
Subject: [PATCH] remove kafka topic autocreation

---
 internal/integrations/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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,
 	}