Kafka出站频道无法从频道接收消息

ifsvaxew  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(349)

有一个频道:

<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接收信息?

qmb5sa22

qmb5sa221#

你的 auto-startup 设置为false,因此在启动应用程序上下文时,没有订阅服务器 sampleChannel . 套 auto-startup 是真的。或者改变你的想法 sampleChannel 可轮询发布订阅频道。

相关问题