Spring Boot Kafka @SendTo无法读取kafka_replyTopic标头

问题描述

在Spring Boot应用程序的使用者接收器上,我正在使用@SendTo批注,而没有任何参数。收到的消息包含标题“ Kafka_replyTopic”,但是@SendTo无法读取它,并且kafka在发送答复时引发异常:

Listener Failed; nested exception is java.lang.IllegalStateException: With no topic header,a defaultTopic is required

解决方法

我通过在消费者应用程序中将spring-boot-starter-parent版本设置为与生产者应用程序中的版本相同(2.3.2.RELEASE)来解决了该问题

我不知道问题是否出在消费者应用程序中的旧版本本身(2.2.6.RELEASE版本)还是它的版本与生产者应用程序的版本不同。