Fix distributor

grafana · Feb 18, 2025 · a840cf5 · a840cf5
1 parent 4d5c093
commit a840cf5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)))