This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 87a299a0810 KAFKA-18826: Add global thread metrics (#18953)
add 75f384a0199 MINOR: Cleanup Raft Module (#19284)
No new revisions were added by this update.
Summary of changes:
.../src/main/java/org/apache/kafka/raft/Batch.java | 5 +-
.../java/org/apache/kafka/raft/ControlRecord.java | 17 --
.../java/org/apache/kafka/raft/DynamicVoter.java | 4 +-
.../java/org/apache/kafka/raft/ElectionState.java | 2 +-
.../main/java/org/apache/kafka/raft/Endpoints.java | 13 +-
.../org/apache/kafka/raft/KafkaNetworkChannel.java | 2 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 31 ++--
.../java/org/apache/kafka/raft/LeaderState.java | 2 +-
.../java/org/apache/kafka/raft/QuorumConfig.java | 7 +-
.../java/org/apache/kafka/raft/QuorumState.java | 3 +-
.../main/java/org/apache/kafka/raft/RaftUtil.java | 85 ++++-----
.../java/org/apache/kafka/raft/RequestManager.java | 2 +-
.../java/org/apache/kafka/raft/ResignedState.java | 2 +-
.../main/java/org/apache/kafka/raft/VoterSet.java | 7 +-
.../kafka/raft/internals/BatchAccumulator.java | 3 +-
.../kafka/raft/internals/KafkaRaftMetrics.java | 6 +-
.../apache/kafka/raft/internals/LogHistory.java | 2 +-
.../kafka/raft/internals/RecordsIterator.java | 28 +--
.../kafka/raft/internals/TreeMapLogHistory.java | 2 +-
.../kafka/raft/internals/UpdateVoterHandler.java | 11 +-
.../raft/internals/UpdateVoterHandlerState.java | 72 --------
.../kafka/raft/internals/VoterSetHistory.java | 11 +-
.../apache/kafka/snapshot/RawSnapshotReader.java | 4 +-
.../kafka/snapshot/RecordsSnapshotWriter.java | 10 +-
.../org/apache/kafka/snapshot/SnapshotReader.java | 4 +-
.../org/apache/kafka/snapshot/SnapshotWriter.java | 2 +-
.../org/apache/kafka/raft/CandidateStateTest.java | 17 +-
.../org/apache/kafka/raft/DynamicVoterTest.java | 4 +-
.../org/apache/kafka/raft/DynamicVotersTest.java | 6 +-
.../org/apache/kafka/raft/ElectionStateTest.java | 22 ++-
.../java/org/apache/kafka/raft/EndpointsTest.java | 3 +-
.../kafka/raft/FileQuorumStateStoreTest.java | 9 +-
.../org/apache/kafka/raft/FollowerStateTest.java | 4 +-
.../apache/kafka/raft/KafkaNetworkChannelTest.java | 63 +++----
.../kafka/raft/KafkaRaftClientPreVoteTest.java | 8 +-
.../kafka/raft/KafkaRaftClientReconfigTest.java | 59 ++++---
.../kafka/raft/KafkaRaftClientSnapshotTest.java | 110 ++++++------
.../org/apache/kafka/raft/KafkaRaftClientTest.java | 189 ++++++++++-----------
.../org/apache/kafka/raft/LeaderStateTest.java | 23 ++-
.../test/java/org/apache/kafka/raft/MockLog.java | 3 +-
.../java/org/apache/kafka/raft/MockLogTest.java | 15 +-
.../apache/kafka/raft/ProspectiveStateTest.java | 22 +--
.../org/apache/kafka/raft/QuorumStateTest.java | 36 ++--
.../apache/kafka/raft/RaftClientTestContext.java | 14 +-
.../apache/kafka/raft/RaftEventSimulationTest.java | 5 +-
.../java/org/apache/kafka/raft/RaftUtilTest.java | 23 ++-
.../org/apache/kafka/raft/ReplicatedCounter.java | 7 +-
.../org/apache/kafka/raft/RequestManagerTest.java | 2 +-
.../org/apache/kafka/raft/ResignedStateTest.java | 11 +-
.../java/org/apache/kafka/raft/VoterSetTest.java | 13 +-
.../kafka/raft/internals/BatchAccumulatorTest.java | 29 ++--
.../kafka/raft/internals/BatchBuilderTest.java | 8 +-
.../kafka/raft/internals/KafkaRaftMetricsTest.java | 3 +-
.../raft/internals/MemoryBatchReaderTest.java | 10 +-
.../raft/internals/RecordsBatchReaderTest.java | 4 +-
.../kafka/raft/internals/RecordsIteratorTest.java | 63 +++----
.../kafka/snapshot/SnapshotWriterReaderTest.java | 7 +-
57 files changed, 470 insertions(+), 659 deletions(-)
delete mode 100644
raft/src/main/java/org/apache/kafka/raft/internals/UpdateVoterHandlerState.java
