KIP-125 — ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback

Discussion Consumer

Defines a migration and rollback protocol for upgrading consumer groups from the ZooKeeperConsumerConnector (old high-level consumer using ZooKeeper for group coordination) to the new KafkaConsumer (broker-coordinated group protocol) without downtime. The two consumers use incompatible coordination systems, making a direct in-place migration risky and previously requiring full consumer group downtime.

Protocol Impact

OffsetCommit · DescribeGroups

Details