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

Posted to commits@kafka.apache.org by cm...@apache.org on 2024/07/26 23:26:00 UTC

(kafka) branch trunk updated (a0f6e6f816c -> da32dcab2c4)

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

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


    from a0f6e6f816c KAFKA-16192: Introduce transaction.version and usage of flexible records to coordinators (#16183)
     add da32dcab2c4 KAKFA-16537; Implement remove voter RPC (#16670)

No new revisions were added by this update.

Summary of changes:
 ...sException.java => VoterNotFoundException.java} |   7 +-
 .../org/apache/kafka/common/protocol/Errors.java   |   4 +-
 .../main/scala/kafka/server/ControllerApis.scala   |   2 +-
 .../org/apache/kafka/raft/KafkaRaftClient.java     | 117 ++++-
 .../java/org/apache/kafka/raft/LeaderState.java    |  60 ++-
 .../main/java/org/apache/kafka/raft/RaftUtil.java  |  31 ++
 .../kafka/raft/internals/AddVoterHandler.java      |  57 +--
 .../kafka/raft/internals/RemoveVoterHandler.java   | 186 ++++++++
 .../raft/internals/RemoveVoterHandlerState.java    |  53 +++
 .../org/apache/kafka/raft/internals/VoterSet.java  |   8 +-
 .../kafka/raft/KafkaRaftClientReconfigTest.java    | 526 ++++++++++++++++++++-
 .../org/apache/kafka/raft/KafkaRaftClientTest.java |   7 +-
 .../apache/kafka/raft/RaftClientTestContext.java   |  45 +-
 .../apache/kafka/raft/internals/VoterSetTest.java  |  10 +
 14 files changed, 1032 insertions(+), 81 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/errors/{TopicExistsException.java => VoterNotFoundException.java} (84%)
 create mode 100644 raft/src/main/java/org/apache/kafka/raft/internals/RemoveVoterHandler.java
 create mode 100644 raft/src/main/java/org/apache/kafka/raft/internals/RemoveVoterHandlerState.java