修复sink插件franzKafka无法自动创建topic的问题 (#641)

Co-authored-by: sunbink <o1Haxpgz3>
loggie-io · Nov 6, 2023 · 342e58a · 342e58a
1 parent 8e89d72
commit 342e58a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/sink/franz/sink.go b/pkg/sink/franz/sink.go
@@ -99,6 +99,7 @@ func (s *Sink) Start() error {
 		kgo.SeedBrokers(c.Brokers...),
 		kgo.ProducerBatchCompression(getCompression(c.Compression)),
 		kgo.WithLogger(&logger),
+		kgo.AllowAutoTopicCreation(),
 	}
 
 	if c.BatchSize > 0 {