我正在经历 Spring Kafka2.7.0。我有一个用例，我想恢复一些分区。在它们恢复之后，我想寻找它们的补偿。我想知道我复职的时候，会不会有人打电话给我？如果没有，是否还有其他回电？
aydmsdu91#
当分区恢复时（通过该方法请求恢复后），容器发布 ConsumerPartitionResumedEvent ; 您可以使用 @EventListener 方法或方法 ApplicationListener<ConsumerPartitionResumedEvent> 豆子。事件不提供对 Consumer 所以你需要在 ConsumerSeekAware 由侦听器实现的回调。最简单的方法就是让你的听众扩展 AbstractConsumerSeekAware .https://docs.spring.io/spring-kafka/docs/current/reference/html/#seek
ConsumerPartitionResumedEvent
@EventListener
ApplicationListener<ConsumerPartitionResumedEvent>
Consumer
ConsumerSeekAware
AbstractConsumerSeekAware
1条答案
按热度按时间aydmsdu91#
当分区恢复时（通过该方法请求恢复后），容器发布
ConsumerPartitionResumedEvent; 您可以使用@EventListener方法或方法ApplicationListener<ConsumerPartitionResumedEvent>豆子。事件不提供对
Consumer所以你需要在ConsumerSeekAware由侦听器实现的回调。最简单的方法就是让你的听众扩展AbstractConsumerSeekAware.https://docs.spring.io/spring-kafka/docs/current/reference/html/#seek