Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
3.7.0, 3.7.1
-
None
Description
The RemoteCopyLagSegment is off by 1 because it also includes the active segment into account while the RemoteCopyLagBytes does substract the size of active segment:
long bytesLag = log.onlyLocalLogSegmentsSize() - log.activeSegment().size(); String topic = topicIdPartition.topic(); int partition = topicIdPartition.partition(); long segmentsLag = log.onlyLocalLogSegmentsCount(); brokerTopicStats.recordRemoteCopyLagBytes(topic, partition, bytesLag); brokerTopicStats.recordRemoteCopyLagSegments(topic, partition, segmentsLag);
Attachments
Issue Links
- is a child of
-
KAFKA-16947 Kafka Tiered Storage V2
- Open
- links to