参考的这篇内容,目前推送消息全部失败了。
以下为错误日志,提示kafka没有生产者,但是我生产者的topic和mqtt都已经配了同样的名字啊
以下为连接器和规则
docker部署,镜像用的emqx/emqx-enterprise:5.8.6
参考的这篇内容,目前推送消息全部失败了。
以下为错误日志,提示kafka没有生产者,但是我生产者的topic和mqtt都已经配了同样的名字啊
以下为连接器和规则
docker部署,镜像用的emqx/emqx-enterprise:5.8.6
你的日志红包部分已经显示 消息已经被规则引擎的 select 选中了,只是在去 kafka 没有成功,应该是你的 kafka 生产者的配置不对(大概率是 topic 配错了,不过一般 在 kafka 里面没有topic,日志也会报错的,我不太明白为什么你的日志没有提示)
我在本地试了一下文档里面的步骤,是成功的。
如果只是从mqtt转发数据到kafka,有没有必要设置Kafka 消费者连接器?
没有必要。