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 c1a54671e8f MINOR: Bump trunk to 3.5.0-SNAPSHOT (#12960)
add d40561e90ab KAFKA-14427 ZK client support for migrations (#12946)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 1 +
.../main/scala/kafka/server/ZkAdminManager.scala | 27 +-
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 333 ++++++++++++++--
core/src/main/scala/kafka/zk/ZkData.scala | 9 +-
.../main/scala/kafka/zk/ZkMigrationClient.scala | 441 +++++++++++++++++++++
.../kafka/zk/ZkMigrationIntegrationTest.scala | 105 +++++
.../unit/kafka/server/ZkAdminManagerTest.scala | 28 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 51 ++-
.../unit/kafka/zk/ZkMigrationClientTest.scala | 353 +++++++++++++++++
.../org/apache/kafka/image/ClientQuotasImage.java | 3 +-
.../kafka/metadata/migration/MigrationClient.java | 91 +++++
.../migration/ZkMigrationLeadershipState.java | 49 ++-
12 files changed, 1423 insertions(+), 68 deletions(-)
create mode 100644 core/src/main/scala/kafka/zk/ZkMigrationClient.scala
create mode 100644
core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala
create mode 100644
core/src/test/scala/unit/kafka/zk/ZkMigrationClientTest.scala
create mode 100644
metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClient.java
