auto create topics in kafka producer (#678)

ozontech · Sep 20, 2024 · b5386e3 · b5386e3
1 parent 201f324
commit b5386e3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/plugin/output/kafka/client.go b/plugin/output/kafka/client.go
@@ -21,6 +21,7 @@ func NewClient(c *Config, l *zap.Logger) *kgo.Client {
 		kgo.MaxBufferedRecords(c.BatchSize_),
 		kgo.ProducerBatchMaxBytes(int32(c.MaxMessageBytes_)),
 		kgo.ProducerLinger(1 * time.Millisecond),
+		kgo.AllowAutoTopicCreation(),
 	}...)
 
 	switch c.Compression {