我试图按照示例文档设置消息。我的所有服务和类都用组件或服务注解进行了修饰,但我仍然得到以下例外:
org.springframework.messaging.messagedeliveryexception:dispatcher没有频道“unknown.channel.name”的订阅服务器
应用程序设置增加了:cloud:stream:kafka:binder:brokers:localhost zk nodes:localhost bindings:subscribablechannel:destination:matrics messagechannel:destination:matrics content type:application/json
谢谢你的帮助/指点-
致以最诚挚的问候-
1条答案
按热度按时间kxeu7u2r1#
我最终发现,问题不是spring云消息传递的配置错误,而是代码执行的顺序问题:即我的代码在spring云有时间设置kafka通道之前发送执行的消息。
使用smartlifecycle界面,我可以确保代码在初始化后执行,现在可以正常工作-
这个错误消息让我大吃一惊,因为它似乎表明存在配置问题。