在方法上使用@KafkaListener 消费。我有什么方法可以跟踪我的消费者的距离

Question

我正在使用 Spring boot，特别是 spring-kafka 库，用于从 kafka 中消费。

我在使用消息的方法之一上有一个带有@KafkaListener 注释的类。我能够读取消息。我意识到它是一个主题，并且基于生产者的消息不断传入。 我想要某种提示，我在最后一个偏移量，这样我就可以触发我与另一个来源的重新协调逻辑。我怎样才能掌握这个提示。有没有我可以订阅/收听的事件？

Answer 1

您可以设置容器idleEventInterval 属性，并且（每个消费者线程）将在该时间间隔内未收到任何记录时发出ListenerContainerIdleEvent。

使用ApplicationListener 或@EventListener 方法来使用事件。