有一个频道:
<integration:channel id="sampleChannel">
</integration:channel>
还有一个kafka出站通道,通道属性为samplechannel值:
<int-kafka:outbound-channel-adapter id="kafkaOutboundChannelAdapter"
kafka-template="template"
auto-startup="false"
channel="sampleChannel"
topic="foo"
sync="false"
send-failure-channel="errorChannel"
partition-id-expression="1">
</int-kafka:outbound-channel-adapter>
当消息发送并到达samplechannel时,此异常引发:
org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'org.springframework.context.support.ClassPathXmlApplicationContext@1623b78d.sampleChannel'
为什么Kafka不能从samplechannel接收信息?
1条答案
按热度按时间qmb5sa221#
你的
auto-startup
设置为false,因此在启动应用程序上下文时,没有订阅服务器sampleChannel
. 套auto-startup
是真的。或者改变你的想法sampleChannel
可轮询发布订阅频道。