#java #spring-boot #kafka-consumer-api #spring-kafka
#java #весенняя загрузка #kafka-потребитель-api #spring-кафка
Вопрос:
Я использую аннотацию @SendTo без аргументов для получателя-потребителя в приложении spring boot. Полученное сообщение содержит заголовок «Kafka_replyTopic», но @SendTo не может его прочитать, и kafka выдает исключение при отправке ответа:
Listener failed; nested exception is java.lang.IllegalStateException: With no topic header, a defaultTopic is required
Ответ №1:
Я решил это, установив версию spring-boot-starter-parent в приложении-потребителе такой же, как и в приложении-производителе (версия 2.3.2.RELEASE)
Я не знаю, была ли проблема в самой старой версии (v. 2.2.6.RELEASE) в приложении-потребителе или в том, что его версия отличалась от версии приложения-производителя.
Комментарии:
1. Я предполагаю, что вы возвращаете
Message<?>— это было действительно изменение в spring-kafka 2.5 (добавлено при загрузке 2.3). Обычно лучше показывать сигнатуру метода прослушивателя при задании подобных вопросов.2. Да я использую сообщение<?>