[GitHub] [kafka] hachikuji commented on a change in pull request #9531: KAFKA-10661; Add new resigned state for graceful shutdown/initialization

hachikuji commented on a change in pull request #9531: URL: https://github.com/apache/kafka/pull/9531#discussion_r519969208 ## File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java ## @@ -1601,7 +1618,12 @@ private long pollFollower(long currentTimeMs)

[GitHub] [kafka] hachikuji commented on a change in pull request #9531: KAFKA-10661; Add new resigned state for graceful shutdown/initialization

hachikuji commented on a change in pull request #9531: URL: https://github.com/apache/kafka/pull/9531#discussion_r519968145 ## File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java ## @@ -21,18 +21,21 @@ import org.slf4j.Logger; import java.io.IOException;

[GitHub] [kafka] hachikuji commented on a change in pull request #9531: KAFKA-10661; Add new resigned state for graceful shutdown/initialization

hachikuji commented on a change in pull request #9531: URL: https://github.com/apache/kafka/pull/9531#discussion_r519965008 ## File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java ## @@ -21,18 +21,21 @@ import org.slf4j.Logger; import java.io.IOException;

[GitHub] [kafka] hachikuji commented on a change in pull request #9531: KAFKA-10661; Add new resigned state for graceful shutdown/initialization

hachikuji commented on a change in pull request #9531: URL: https://github.com/apache/kafka/pull/9531#discussion_r516198568 ## File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java ## @@ -1560,9 +1558,34 @@ private long pollLeader(long currentTimeMs) {