Получить сообщение с указанным ключом с помощью Kafka Listener vs Kafka Consumer

Question

Я использую приложение SpringBoot для создания или потребления / прослушивания сообщений Kafka.

Я создаю сообщение в topi c и получаю / слушаю указанное сообщение c, сравнивая messageKey и затем отправьте использованное сообщение для дальнейшей обработки.

Я застрял с тем, какой подход лучше подходит для моего требования, чтобы получить конкретное c сообщение, т.е. Kafka Listener или Kafka Consumer что?

Answer 1

KafkaListener - это концепция, определяемая Spring c, охватывающая API-интерфейс Kafka Consumer.

Невозможно получить сообщение по определенному смещению по заданному ключу. Вы должны рассчитать раздел, а затем отсканировать все смещение