dajac commented on code in PR #22444:
URL: https://github.com/apache/kafka/pull/22444#discussion_r3346775461
##########
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/PartitionWriter.java:
##########
@@ -33,8 +33,24 @@ public interface PartitionWriter {
/**
* Listener allowing to listen to high watermark changes. This is meant
* to be used in conjunction with {@link
PartitionWriter#append(TopicPartition, VerificationGuard, MemoryRecords,
short)}.
+ * <p>
+ * High watermark updates are delivered only while this broker is the
leader of the
+ * partition. Once the partition is no longer led by this broker (it
transitions to
+ * follower, is deleted or fails), no further updates are delivered. This
guarantee
Review Comment:
Updated the comment.
--
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]
