You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jg...@apache.org on 2020/11/09 20:53:27 UTC

[kafka] branch trunk updated (d61dc0c -> f49c6c2)

This is an automated email from the ASF dual-hosted git repository.

jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from d61dc0c  MINOR: Update jetty to 9.4.33
     add f49c6c2  KAFKA-10661; Add new resigned state for graceful shutdown/initialization (#9531)

No new revisions were added by this update.

Summary of changes:
 .../common/requests/EndQuorumEpochRequest.java     |   5 +-
 .../common/message/EndQuorumEpochRequest.json      |   4 +-
 .../unit/kafka/raft/KafkaNetworkChannelTest.scala  |   5 +-
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   2 +-
 .../org/apache/kafka/raft/KafkaRaftClient.java     | 251 +++++++++++++--------
 .../java/org/apache/kafka/raft/QuorumState.java    |  66 ++++--
 .../java/org/apache/kafka/raft/ResignedState.java  | 144 ++++++++++++
 .../org/apache/kafka/raft/KafkaRaftClientTest.java | 227 ++++++++++++++-----
 .../org/apache/kafka/raft/QuorumStateTest.java     |  72 ++++--
 .../apache/kafka/raft/RaftClientTestContext.java   |  49 ++--
 ...{VotedStateTest.java => ResignedStateTest.java} |  37 +--
 11 files changed, 639 insertions(+), 223 deletions(-)
 create mode 100644 raft/src/main/java/org/apache/kafka/raft/ResignedState.java
 copy raft/src/test/java/org/apache/kafka/raft/{VotedStateTest.java => ResignedStateTest.java} (67%)