是否可以在ConsumerBalanceListener回调的onPartionsReversed()方法中执行commitsync()?

a0x5cqrl  于 2021-07-15  发布在  Kafka
关注(0)|答案(0)|浏览(233)

对于kafka使用者,是否可以在ConsumerBalanceListener回调的onPartionsReversed()方法中执行commitsync()??否则就会出错。

public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
           consumer.commitSync(); //or consumer.commitAsync()
       }

首先我想知道上面的代码是否有效。
如果在执行commitsync()时,使用者可能只处理了少数轮询记录,但使用者要求代理对所有轮询记录进行提交。如果上面的代码工作,如果提交成功。然后,如果消费者在处理所有先前轮询的记录之前崩溃了,那么消费者端的数据将丢失。我说的对吗??

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题