使用@KafkaListener 时,我可以获取对底层 KafkaConsumer 的引用,因为我想读取 endOffsets
When using @KafkaListener can I get a reference to the underlying KafkaConsumer as I want to read the endOffsets
当我使用 @KafkaListener
时,我能否获得对基础 KafkaConsumer
的引用,因为我想阅读 endOffsets
只需在侦听器方法中添加一个 Consumer<?, ?>
参数即可。
使用者不是线程安全的,因此您应该只在侦听器线程上调用它。
需要 2.0 或更高版本;当前版本是 2.2.3.
当我使用 @KafkaListener
时,我能否获得对基础 KafkaConsumer
的引用,因为我想阅读 endOffsets
只需在侦听器方法中添加一个 Consumer<?, ?>
参数即可。
使用者不是线程安全的,因此您应该只在侦听器线程上调用它。
需要 2.0 或更高版本;当前版本是 2.2.3.