grafana
diff --git a/‎pkg/kafka/partition/reader_service.go
+1-1 b/‎pkg/kafka/partition/reader_service.go
+1-1
@@ -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
Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ func newReaderService(`
`120`	`120`	`consumerFactory: consumerFactory,`
`121`	`121`	`logger: log.With(logger, "partition", reader.Partition(), "consumer_group", reader.ConsumerGroup()),`
`122`	`122`	`metrics: newServiceMetrics(reg),`
`123`		`- lastProcessedOffset: -1,`
	`123`	`+ lastProcessedOffset: kafkaEndOffset,`
`124`	`124`	`}`
`125`	`125`
`126`	`126`	`// Create the committer`