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 f749af557a4 MINOR: add some unit test for common Utils (#16549)
add 8aee314a466 KAFKA-16667 Avoid stale read in KRaftMigrationDriver
(#15918)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 4 +-
.../kafka/zk/ZkMigrationFailoverTest.scala | 148 ++++++++++++++-
.../metadata/migration/KRaftMigrationDriver.java | 205 ++++++++++++++++-----
.../metadata/migration/KRaftMigrationZkWriter.java | 76 ++++----
.../tests/core/zookeeper_migration_test.py | 78 --------
5 files changed, 345 insertions(+), 166 deletions(-)
