kafka—再均衡监听器

再均衡监听器 再均衡监听器用来处理发生再均衡动作前后的一些准备或收尾动作

//指定主题subscribe consumer.subscribe(Collections.singletonList(TOPIC), new ConsumerRebalanceListener() { /** * 消费者组停止消费前的后续工作，例如位移的提交 */ @Override public void onPartitionsRevoked(Collection<TopicPartition> partitions) { //例如将偏移量存入到DB } /** * 消费者停止消费，均衡分区和消费者 */ @Override public void onPartitionsAssigned(Collection<TopicPartition> partitions) { //从DB读取消费位移，用seek()指定位移 } });