kafka rebalance ConsumerRebalanceListener的写法

背景           kafka 在有新消费者加入或者撤出时，会触发rebalance操做，在subscibe订阅主题的时候，咱们能够编写回掉函数，在触发rebalance操做以前和触发成功以后，提交相应偏移量和获取拉取偏移量java 代码          订阅主题的时候服务器 consumer.subscribe(Collections.singletonList(topic), new

>>阅读原文<<