对于kafka使用者,是否可以在ConsumerBalanceListener回调的onPartionsReversed()方法中执行commitsync()??否则就会出错。
public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
consumer.commitSync(); //or consumer.commitAsync()
}
首先我想知道上面的代码是否有效。
如果在执行commitsync()时,使用者可能只处理了少数轮询记录,但使用者要求代理对所有轮询记录进行提交。如果上面的代码工作,如果提交成功。然后,如果消费者在处理所有先前轮询的记录之前崩溃了,那么消费者端的数据将丢失。我说的对吗??
暂无答案!
目前还没有任何答案,快来回答吧!