kevin-wu24 commented on code in PR #17500:
URL: https://github.com/apache/kafka/pull/17500#discussion_r1800207969
##########
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##########
@@ -258,7 +260,8 @@ public KafkaRaftClient(
localSupportedKRaftVersion,
logContext,
new Random(),
- quorumConfig
+ quorumConfig,
+ new HashSet<>()
Review Comment:
Looks like the log layer gets the batch associated with a `targetOffset`
from `FileRecords#searchForOffsetWithSize`, but it currently returns the last
offset included in that batch. It looks safe to change this to return the base
offset instead since the offset field is never being accessed, so we can
retrieve the batch start offset for a given offset. `LogSegment#read` also
needs to construct `LogOffsetMetadata` with this batch start offset instead of
the `startOffset` that is passed into the method.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
