enter code here Я использую потоки весенних облаков для получения сообщения от Kafka.
Можно ли прочитать ключ сообщения Kafka из кода?
У меня есть тема Кафки, в которой обычно есть 2 типа сообщений.Требуемое действие зависит от ключа сообщения.Я вижу, что у весенней документации есть только следующее, чтобы прочитать сообщение.Здесь мне нужно указать фактическое отображение сообщения (класс Greetings здесь).Однако мне нужен способ, с помощью которого я могу прочитать ключ сообщения и определить десериализуемый Pojo
открытый класс GreetingsListener {
@StreamListener(GreetingsProcessor.INPUT)
public void handleGreetings(@Payload Greetings request) {
}
}