Set topic creation

grafana · Aug 27, 2024 · 7044778 · 7044778
1 parent 856388a
commit 7044778
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/ingester-rf1/kafka_tee.go b/pkg/ingester-rf1/kafka_tee.go
@@ -46,6 +46,7 @@ func NewKafkaTee(
 		//commonKafkaClientOptions(kafkaCfg, metrics, logger),
 		kgo.RequiredAcks(kgo.AllISRAcks()),
 		kgo.DefaultProduceTopic("rf1"),
+		kgo.AllowAutoTopicCreation(),
 
 		// We set the partition field in each record.
 		kgo.RecordPartitioner(kgo.ManualPartitioner()),