diff --git a/pkg/ingester-rf1/kafka_tee.go b/pkg/ingester-rf1/kafka_tee.go
index a70a65d05204e..4ece77268c880 100644
--- 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()),