在 method.What 上使用 @KafkaListener 消费是我跟踪我的 Consumer 有多远的方法
consuming using @KafkaListener on a method.What are the means for me to keep track of how far along my Consumer is
我正在使用 Spring 引导，特别是 spring-kafka 库用于从 kafka 中使用。
我有一个 Class 在其中一种使用方法上带有 @KafkaListener 注释 messages.I 能够读取消息。我意识到这是一个话题，并且消息不断根据制作人而来。
我想要某种提示，表明我处于最后一个偏移量，这样我就可以用另一个 source.How 触发我的重新协调逻辑，我可以得到这个 cue.Is 有一个事件我可以 subscribe/listen 到 ?
您可以设置容器 idleEventInterval 属性 并且（每个消费者线程）将在该时间间隔内未收到任何记录时发出 ListenerContainerIdleEvent。
使用 ApplicationListener 或 @EventListener 方法来使用事件。
我正在使用 Spring 引导，特别是 spring-kafka 库用于从 kafka 中使用。
我有一个 Class 在其中一种使用方法上带有 @KafkaListener 注释 messages.I 能够读取消息。我意识到这是一个话题，并且消息不断根据制作人而来。 我想要某种提示，表明我处于最后一个偏移量，这样我就可以用另一个 source.How 触发我的重新协调逻辑，我可以得到这个 cue.Is 有一个事件我可以 subscribe/listen 到 ?
您可以设置容器 idleEventInterval 属性 并且（每个消费者线程）将在该时间间隔内未收到任何记录时发出 ListenerContainerIdleEvent。
使用 ApplicationListener 或 @EventListener 方法来使用事件。