mumrah opened a new pull request, #12815: URL: https://github.com/apache/kafka/pull/12815
This PR adds some of the implementation of KIP-866. Since this KIP is still under discussion, this PR should not be merged to `trunk`. A few new things are defined here: * MigrationClient: an interface in the `metadata` package that abstracts some ZK things we want to do during the migration * ZkMigrationClient: a Scala implementation of MigrationClient that has dependencies on KafkaZkClient * ZkMetadataConsumer: a callback used by the QuorumController to receive the migrated ZK data as records * KRaftMetadataListener: a callback for handling leader changes and records (this is temporary/throw-away code) * KRaftMigrationDriver: the main class that manages the state and orchestrates the migration A ducktape test is also included that creates a topic in ZK mode, and verifies that it later exists in KRaft mode. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
