We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ae588d0 commit 10727b7Copy full SHA for 10727b7
raft/src/main/java/org/apache/kafka/raft/LeaderState.java
@@ -720,7 +720,6 @@ private boolean maybeUpdateHighWatermark() {
720
721
int indexOfHw = voterStates.size() / 2;
722
Optional<LogOffsetMetadata> highWatermarkUpdateOpt = followersByDescendingFetchOffset.get(indexOfHw).endOffset;
723
- highWatermark.ifPresent(this::updateCommittedVoter);
724
725
if (highWatermarkUpdateOpt.isPresent()) {
726
0 commit comments