kafka rebalance ConsumerRebalanceListener的寫法

背景           kafka 在有新消費者加入或者撤出時，會觸發rebalance操做，在subscibe訂閱主題的時候，咱們能夠編寫回掉函數，在觸發rebalance操做以前和觸發成功以後，提交相應偏移量和獲取拉取偏移量java 代碼          訂閱主題的時候服務器 consumer.subscribe(Collections.singletonList(topic), new

>>阅读原文<<