问题描述
在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版本)还是它的版本与生产者应用程序的版本不同。