Revert AllowAutoTopicCreation: false setting

banzaicloud · Oct 14, 2022 · cabba3e · cabba3e
1 parent 8f3b52c
commit cabba3e
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/internal/kafka/producer.go b/internal/kafka/producer.go
@@ -28,10 +28,9 @@ func NewProducer(bootStrapServer string, topic string, logger log.Logger) *Produ
 func (p *Producer) Produce(ctx context.Context, message string) error {
 	if p.writer == nil {
 		p.writer = &kafka.Writer{
-			Topic:                  p.topic,
-			Addr:                   kafka.TCP(p.bootstrapServer),
-			Logger:                 p.logger,
-			AllowAutoTopicCreation: false,
+			Topic:  p.topic,
+			Addr:   kafka.TCP(p.bootstrapServer),
+			Logger: p.logger,
 		}
 	}