Spring 启动 Kafka @SendTo 无法读取 kafka_replyTopic header
Spring Boot Kafka @SendTo can't read kafka_replyTopic header
我在 spring 引导应用程序的消费者接收器上使用不带参数的 @SendTo 注释。收到的消息包含header“Kafka_replyTopic”，但是@SendTo无法读取它并且kafka在发送回复时抛出异常：
Listener failed; nested exception is java.lang.IllegalStateException: With no topic header, a defaultTopic is required
我通过将消费者应用程序中的 spring-boot-starter-parent 版本设置为与生产者应用程序中的版本相同 (v. 2.3.2.RELEASE)
解决了这个问题
我不知道问题出在消费者应用程序中的旧版本本身 (v. 2.2.6.RELEASE) 还是它的版本与生产者应用程序的版本不同。
我在 spring 引导应用程序的消费者接收器上使用不带参数的 @SendTo 注释。收到的消息包含header“Kafka_replyTopic”，但是@SendTo无法读取它并且kafka在发送回复时抛出异常：
Listener failed; nested exception is java.lang.IllegalStateException: With no topic header, a defaultTopic is required
我通过将消费者应用程序中的 spring-boot-starter-parent 版本设置为与生产者应用程序中的版本相同 (v. 2.3.2.RELEASE)
解决了这个问题我不知道问题出在消费者应用程序中的旧版本本身 (v. 2.2.6.RELEASE) 还是它的版本与生产者应用程序的版本不同。