使用@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.