调用listener.resumePartiton()时是否调用onPartitonsAssigned



我正在经历弹簧kafka 2.7.0。我有一个用例,我想恢复一些分区。在它们恢复后,我想寻求它们的补偿。我想知道当我恢复时,会调用onPartitionsAssigned吗?

如果没有,是否还有其他回调?

恢复分区时(通过该方法请求恢复后(,容器发布ConsumerPartitionResumedEvent;您可以使用@EventListener方法或ApplicationListener<ConsumerPartitionResumedEvent>bean捕获这些事件。

该事件不提供对Consumer的直接访问,因此需要对侦听器实现的ConsumerSeekAware回调执行查找。最简单的方法是让您的侦听器扩展AbstractConsumerSeekAware

https://docs.spring.io/spring-kafka/docs/current/reference/html/#seek

最新更新