From a840cf5281283a71dfe360b5d3a514d923032df2 Mon Sep 17 00:00:00 2001 From: Periklis Tsirakidis Date: Tue, 18 Feb 2025 09:45:52 +0100 Subject: [PATCH] Fix distributor --- pkg/distributor/distributor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/distributor/distributor.go b/pkg/distributor/distributor.go index 175a0d9263163..a14315d82784a 100644 --- a/pkg/distributor/distributor.go +++ b/pkg/distributor/distributor.go @@ -1123,7 +1123,7 @@ func (d *Distributor) sendStreamToKafka(ctx context.Context, stream KeyedStream, } // Add metadata record - metadataRecord := kafka.EncodeStreamMetadata(partitionID, d.cfg.KafkaConfig.Topic, tenant, stream.HashNoShard) + metadataRecord := kafka.EncodeStreamMetadata(partitionID, d.cfg.KafkaConfig.Topic, tenant, stream.HashNoShard, stream.RingToken) records = append(records, metadataRecord) d.kafkaRecordsPerRequest.Observe(float64(len(records)))