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 5b0e96d7855 KAFKA-17034 Tweak some descriptions in FeatureUpdate
(#16448)
add adee6f0cc11 KAFKA-16527; Implement request handling for updated KRaft
RPCs (#16235)
No new revisions were added by this update.
Summary of changes:
...xception.java => InvalidVoterKeyException.java} | 6 +-
.../org/apache/kafka/common/protocol/Errors.java | 4 +-
.../common/requests/BeginQuorumEpochRequest.java | 17 +-
.../common/requests/BeginQuorumEpochResponse.java | 23 -
.../common/requests/EndQuorumEpochRequest.java | 16 +
.../common/requests/EndQuorumEpochResponse.java | 23 -
.../common/requests/FetchSnapshotResponse.java | 29 -
.../apache/kafka/common/requests/VoteRequest.java | 14 -
.../apache/kafka/common/requests/VoteResponse.java | 21 -
.../common/message/BeginQuorumEpochRequest.json | 42 +-
.../common/message/BeginQuorumEpochResponse.json | 41 +-
.../common/message/EndQuorumEpochRequest.json | 49 +-
.../common/message/EndQuorumEpochResponse.json | 41 +-
.../resources/common/message/FetchRequest.json | 8 +-
.../resources/common/message/FetchResponse.json | 6 +-
.../common/message/FetchSnapshotRequest.json | 43 +-
.../common/message/FetchSnapshotResponse.json | 72 +-
.../main/resources/common/message/VoteRequest.json | 41 +-
.../resources/common/message/VoteResponse.json | 41 +-
.../main/scala/kafka/network/RequestChannel.scala | 2 +-
core/src/main/scala/kafka/raft/RaftManager.scala | 12 +-
.../main/scala/kafka/server/ControllerApis.scala | 4 +-
.../main/scala/kafka/server/ControllerServer.scala | 9 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 26 +-
.../main/scala/kafka/server/KafkaRaftServer.scala | 2 +
core/src/main/scala/kafka/server/KafkaServer.scala | 4 +
.../src/main/scala/kafka/server/SharedServer.scala | 30 +-
.../scala/kafka/tools/TestRaftRequestHandler.scala | 1 +
.../main/scala/kafka/tools/TestRaftServer.scala | 13 +-
.../unit/kafka/network/SocketServerTest.scala | 5 +-
.../scala/unit/kafka/raft/RaftManagerTest.scala | 20 +-
.../unit/kafka/server/ControllerApisTest.scala | 8 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 21 +-
.../kafka/server/ReplicaFetcherThreadTest.scala | 23 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 4 +-
.../java/org/apache/kafka/raft/CandidateState.java | 9 +-
.../java/org/apache/kafka/raft/ElectionState.java | 12 +-
.../main/java/org/apache/kafka/raft/Endpoints.java | 219 ++++
.../java/org/apache/kafka/raft/EpochState.java | 7 +
.../java/org/apache/kafka/raft/FollowerState.java | 48 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 474 ++++++---
.../apache/kafka/raft/KafkaRaftClientDriver.java | 3 +
.../java/org/apache/kafka/raft/LeaderState.java | 284 ++---
.../java/org/apache/kafka/raft/QuorumState.java | 64 +-
.../java/org/apache/kafka/raft/RaftMessage.java | 2 -
.../java/org/apache/kafka/raft/RaftRequest.java | 43 +-
.../java/org/apache/kafka/raft/RaftResponse.java | 5 -
.../main/java/org/apache/kafka/raft/RaftUtil.java | 432 +++++++-
.../java/org/apache/kafka/raft/RequestManager.java | 2 +-
.../java/org/apache/kafka/raft/ResignedState.java | 8 +
.../org/apache/kafka/raft/UnattachedState.java | 5 +
.../java/org/apache/kafka/raft/VotedState.java | 5 +
.../kafka/raft/internals/BlockingMessageQueue.java | 5 -
.../apache/kafka/raft/internals/ReplicaKey.java | 23 +-
.../org/apache/kafka/raft/internals/VoterSet.java | 137 +--
.../org/apache/kafka/raft/CandidateStateTest.java | 17 +-
.../org/apache/kafka/raft/ElectionStateTest.java | 17 +-
.../kafka/raft/FileQuorumStateStoreTest.java | 5 +-
.../org/apache/kafka/raft/FollowerStateTest.java | 26 +-
.../apache/kafka/raft/KafkaNetworkChannelTest.java | 19 +-
.../kafka/raft/KafkaRaftClientSnapshotTest.java | 396 ++++---
.../org/apache/kafka/raft/KafkaRaftClientTest.java | 1083 +++++++++++++-------
.../org/apache/kafka/raft/LeaderStateTest.java | 931 ++++++++++-------
.../org/apache/kafka/raft/QuorumStateTest.java | 214 ++--
.../apache/kafka/raft/RaftClientTestContext.java | 516 ++++++++--
.../apache/kafka/raft/RaftEventSimulationTest.java | 18 +-
.../org/apache/kafka/raft/ResignedStateTest.java | 28 +-
.../org/apache/kafka/raft/UnattachedStateTest.java | 20 +-
.../java/org/apache/kafka/raft/VotedStateTest.java | 35 +-
.../kafka/raft/internals/KafkaRaftMetricsTest.java | 21 +-
.../apache/kafka/raft/internals/VoterSetTest.java | 94 +-
.../kafka/server/common/MetadataVersion.java | 5 +-
72 files changed, 4067 insertions(+), 1886 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/errors/{SnapshotNotFoundException.java
=> InvalidVoterKeyException.java} (83%)
create mode 100644 raft/src/main/java/org/apache/kafka/raft/Endpoints.java
