This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch 3.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 236973ebf4c MINOR: Update LICENSE-binary following snappy upgrade
(#13791)
new 65f628fd87b KAFKA-15017 Fix snapshot load in dual write mode for
ClientQuotas and SCRAM (#13757)
new f1bb8d17b0c KAFKA-15010 ZK migration failover support (#13758)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../main/scala/kafka/zk/ZkMigrationClient.scala | 6 +
.../kafka/zk/ZkMigrationIntegrationTest.scala | 17 +-
.../zk/migration/ZkAclMigrationClientTest.scala | 5 +-
.../zk/migration/ZkConfigMigrationClientTest.scala | 79 +++++++++-
.../kafka/zk/migration/ZkMigrationClientTest.scala | 8 +-
.../metadata/migration/KRaftMigrationDriver.java | 110 ++++++++++---
...n.java => KRaftMigrationOperationConsumer.java} | 4 +-
.../metadata/migration/KRaftMigrationZkWriter.java | 171 +++++++++++++++------
.../kafka/metadata/migration/MigrationClient.java | 4 +
.../metadata/migration/MigrationDriverState.java | 13 +-
.../migration/ZkMigrationLeadershipState.java | 4 +-
.../java/org/apache/kafka/image/AclsImageTest.java | 4 +-
.../apache/kafka/image/ClientQuotasImageTest.java | 4 +-
.../kafka/image/ConfigurationsImageTest.java | 4 +-
.../org/apache/kafka/image/FeaturesImageTest.java | 4 +-
.../apache/kafka/image/ProducerIdsImageTest.java | 2 +-
.../org/apache/kafka/image/ScramImageTest.java | 4 +-
.../org/apache/kafka/image/TopicsImageTest.java | 2 +-
.../migration/CapturingMigrationClient.java | 12 ++
.../migration/KRaftMigrationDriverTest.java | 78 ++++++++--
.../migration/KRaftMigrationZkWriterTest.java | 143 +++++++++++++++++
tests/kafkatest/services/zookeeper.py | 50 ++++++
.../tests/core/zookeeper_migration_test.py | 119 +++++++++++++-
23 files changed, 721 insertions(+), 126 deletions(-)
copy
metadata/src/main/java/org/apache/kafka/metadata/migration/{KRaftMigrationOperation.java
=> KRaftMigrationOperationConsumer.java} (86%)
create mode 100644
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationZkWriterTest.java
