当前位置: 首页 > 知识库问答 >
问题:

Kafka短信不起作用

傅泉
2023-03-14

我试图将消息设置为示例留档。我所有的服务和类都装饰有组件或服务注释,但我仍然得到以下例外:

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个答案

燕英逸
2023-03-14

我最终发现,问题不是spring cloud消息的错误配置,而是代码执行的顺序问题:即,我的代码在spring cloud有时间设置kafka通道之前发送执行的消息。

使用SmartLifeCycle界面,我能够确保代码在初始化后执行,现在运行良好-

这条错误消息似乎表明存在配置问题,让我大吃一惊。

 类似资料:
  • 嗨,我试图捕捉短信内容和使用我的应用程序,所以我做了一个广播接收器与许可和清单,但当设备接收短信,我的代码不运行,这意味着广播接收器不发射。我也查了这里里里外外的很多文章,有一些: Android短信接收结果到主要活动短信接收不工作 我还尝试在活动onCreate()中动态注册接收器,但没有任何变化 有人知道问题出在哪里吗?它应该只是庆祝一个消息被累犯,这样我就可以继续工作,但接收器似乎甚至没有发

  • 我使用的是Kafka版本0.8.2。在开发过程中,我想我可能需要删除一个主题。所以我所做的是在服务器配置文件中放入以下一行,并启动两台kafka服务器。 当我需要删除一个主题并运行以下命令时, 现在距我运行“删除主题”命令已经17个小时了,但Kafka仍在向我显示该主题已标记为删除。是Kafka的虫子还是我在这里做错了什么?因为在我看来这不正常。有人能就此澄清一下吗?

  • 我用的是Kafka1.0,我增加了批量。大小=100K,用于优化我的制作人性能。但我发现,无论我设定的批次是什么,都没有任何效果。尺寸=100K或1000K或仅1K。此外,我还设定了我的逗留时间。ms=5,但这使性能更差。当我调试Kafka producer的源代码时,如下所示: 我发现了结果的价值。纽巴奇总是正确的,我想这就是为什么这一批。大小没有起任何作用,因为它每次都会唤醒发送者,而不是在b

  • 我的spark streaming版本是2.0,kafka版本是0.10.0.1,Spark-Streaming-Kafka-0-102.11。我使用直接的方式来获取Kafka记录,我现在想限制我在一个批处理中获取的消息的最大数量。所以我设置了max.poll.records值,但它不起作用。spark中的消费者数就是Kafka中的分区数?所以spark流中的最大记录数是max.poll.reco

  • 我们已经实施贝宝支付到我的网站。 我们正在用沙箱测试模式进行检查。付款通过登录与贝宝帐户工作罚款,但没有登录贝宝帐户使用卡选项付款不工作。我正在尝试测试卡的详细信息,它会显示这样的错误信息:“您输入的卡不能用于此付款。请输入其他的借记卡或信用卡号码。” 我有用户所有由贝宝提供的卡号仍有错误 https://developer.paypal.com/webapps/developer/docs/cl

  • 读取 M600 上的短信 如果您在手机上使用短信通知,在您收到新的短信时您会在 M600上看到一项通知。 读取短信 轻触通知。 通过 M600 回复短信 仅适用于与 Android 手机配对的 Polar M600。 您可以在手腕上回复短信。 如需回复短信 轻触通知查看所有短信 从屏幕底部向上滑动查看您可以进行的操作。 轻触Reply(回复)。 请选择您是语音回复、打字回复还是使用表情符号。或从屏