fix: use KafkaEndOffset instead of -1 (#15099)

grafana · Nov 25, 2024 · 2113526 · 2113526
1 parent 7410f10
commit 2113526
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kafka/partition/reader_service.go b/pkg/kafka/partition/reader_service.go
@@ -120,7 +120,7 @@ func newReaderService(
 		consumerFactory:     consumerFactory,
 		logger:              log.With(logger, "partition", reader.Partition(), "consumer_group", reader.ConsumerGroup()),
 		metrics:             newServiceMetrics(reg),
-		lastProcessedOffset: -1,
+		lastProcessedOffset: kafkaEndOffset,
 	}
 
 	// Create the committer