При использовании @KafkaListener я могу получить ссылку на базовый KafkaConsumer, поскольку я хочу прочитать endOffsets

Question

При использовании @KafkaListener можно ли получить ссылку на базовый KafkaConsumer, поскольку я хочу прочитать endOffsets

Answer 1

Просто добавьте параметр Consumer<?, ?> в метод слушателя.

Потребитель не является потокобезопасным, поэтому его следует вызывать только в потоке слушателя.

Требуется 2.0 или более поздняя версия; текущая версия 2.2.3.