我正在经历弹簧kafka 2.7.0。我有一个用例,我想恢复一些分区。在它们恢复后,我想寻求它们的补偿。我想知道当我恢复时,会调用onPartitionsAssigned吗?
如果没有,是否还有其他回调?
恢复分区时(通过该方法请求恢复后(,容器发布ConsumerPartitionResumedEvent
;您可以使用@EventListener
方法或ApplicationListener<ConsumerPartitionResumedEvent>
bean捕获这些事件。
该事件不提供对Consumer
的直接访问,因此需要对侦听器实现的ConsumerSeekAware
回调执行查找。最简单的方法是让您的侦听器扩展AbstractConsumerSeekAware
。
https://docs.spring.io/spring-kafka/docs/current/reference/html/#seek