This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 115a033e3c0 MINOR: Update LICENSE-binary following snappy upgrade
(#13791)
add d27ba5bfba4 KAFKA-15010 ZK migration failover support (#13758)
No new revisions were added by this update.
Summary of changes:
.../main/scala/kafka/zk/ZkMigrationClient.scala | 6 +
.../kafka/zk/ZkMigrationIntegrationTest.scala | 17 ++-
.../zk/migration/ZkAclMigrationClientTest.scala | 5 +-
.../zk/migration/ZkConfigMigrationClientTest.scala | 7 +-
.../kafka/zk/migration/ZkMigrationClientTest.scala | 8 +-
.../metadata/migration/KRaftMigrationDriver.java | 110 ++++++++++++----
...n.java => KRaftMigrationOperationConsumer.java} | 4 +-
.../metadata/migration/KRaftMigrationZkWriter.java | 145 +++++++++++++++------
.../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, 628 insertions(+), 121 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
