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 5af3547c6e7 KAFKA-18572: Update Kafka Streams metric documenation
(#18673)
add b97a130c087 KAFKA-16538; Enable upgrading kraft version for existing
clusters (#19416)
No new revisions were added by this update.
Summary of changes:
.../controller/ConfigurationControlManager.java | 6 +-
.../kafka/controller/FeatureControlManager.java | 88 ++-
...odicTaskFlag.java => KRaftVersionAccessor.java} | 22 +-
.../apache/kafka/controller/QuorumController.java | 3 +-
...te.java => RaftClientKRaftVersionAccessor.java} | 29 +-
.../ConfigurationControlManagerTest.java | 6 +-
.../controller/FeatureControlManagerTest.java | 57 +-
.../kafka/image/publisher/SnapshotEmitterTest.java | 5 +
.../org/apache/kafka/metalog/LocalLogManager.java | 9 +-
.../java/org/apache/kafka/raft/FollowerState.java | 35 +-
.../org/apache/kafka/raft/KafkaRaftClient.java | 163 ++++--
.../java/org/apache/kafka/raft/LeaderState.java | 337 ++++++++++--
.../java/org/apache/kafka/raft/QuorumState.java | 3 +-
.../java/org/apache/kafka/raft/RaftClient.java | 16 +-
.../main/java/org/apache/kafka/raft/VoterSet.java | 43 +-
.../kafka/raft/internals/KRaftVersionUpgrade.java | 65 +++
.../{CloseListener.java => RequestSendResult.java} | 14 +-
.../kafka/raft/internals/UpdateVoterHandler.java | 176 ++++--
.../org/apache/kafka/raft/FollowerStateTest.java | 9 +
.../kafka/raft/KafkaRaftClientReconfigTest.java | 588 ++++++++++++++++++++-
.../org/apache/kafka/raft/LeaderStateTest.java | 366 +++++++++++--
.../java/org/apache/kafka/raft/VoterSetTest.java | 50 +-
.../apache/kafka/server/common/KRaftVersion.java | 19 +-
.../kafka/server/common/KRaftVersionTest.java | 18 +
24 files changed, 1848 insertions(+), 279 deletions(-)
copy metadata/src/main/java/org/apache/kafka/controller/{PeriodicTaskFlag.java
=> KRaftVersionAccessor.java} (56%)
copy
metadata/src/main/java/org/apache/kafka/controller/{BrokerControlState.java =>
RaftClientKRaftVersionAccessor.java} (59%)
create mode 100644
raft/src/main/java/org/apache/kafka/raft/internals/KRaftVersionUpgrade.java
copy raft/src/main/java/org/apache/kafka/raft/internals/{CloseListener.java =>
RequestSendResult.java} (64%)
