ivicar
2018-09-03 16:47:35
等
请问kafka怎么接收MQTT apollo发过来的数据?
我这里的项目是车机端通过MQTT apollo发送到kafka,再将kafka中的数据写到数据库中,但是发送到kafka要怎么去实现?有大神知道思路吗?网上找了一圈没发现有相关的解决方案
@Bean public MqttPahoClientFactory mqttClientFactory() { DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory(); factory.setServerURIs("tcp://demo:1883"); // factory.setUserName("guest"); // factory.setPassword("guest"); return factory; } @Bean public IntegrationFlow mqttInFlow() { return IntegrationFlows.from(mqttInbound()) .transform(p -> p + ", received from MQTT") .handle(logger()) .get(); }
评论
所有回答列表(1)
sessionbest LV2
2018年9月29日
MQTT 与 Kafka 是完全不同的两个东西, MQTT 是协议,是一个技术标准,而 Kafka 是已经实现的开源流处理平台.
kafka可以mqtt协议做..但mqtt apollo是另一种自有协议...完全不是一个东西.无法通讯!
- 等 最代码怎么获取牛币啊?
- 完 谁来告诉我最代码上线的时间,答对者给5牛币,先来先得
- 等 牛友们,大家好,你们做程序员多久了?现在还好吗?
- 完 在微信打开的页面里进行app下载
- 等 最代码2014年欢乐聚声会
- 完 mysql如何查询表数据并且对3个字段降序的SQL?
- 完 最代码牛币机制改革
- 完 成功的在bae上使用了自定义运行环境 jetty+nginx的组合,大家对jetty+nginx优化有哪些心得?
- 完 进来分享一下各位牛牛是如何加入最代码大家庭的?
- 等 为什么java BufferedImage类处理大图直接抛出内存溢出的异常?
- 等 最代码是否开发手机app客户端?
- 完 java程序员学习哪些java的技术?java有哪些框架?都能做哪方面的开发?
- 等 php格式网页文件怎么运行?
- 等 Java volatile值获取的问题
- 等 前端vue,拦截了登录后台后,返回的token,requests拦截token,但是发送请求的时候,就出现跨越异常
- 等 大专本科计算机科班怎么找到Java工作?
- 等 eclipse怎么把三个java swing游戏项目合成一个项目?
- 完 伙伴们,大家都有什么好的解压方式么,分享一下~
- 完 三四线城市,6、7k,运维工作,索然无味,想去辞职上培训,各位牛牛有什么建议嘛
- 等 jsp页面输入中文变成问号
- 等 JPA在线上运行一段时间后报错Caused by: java.lang.IncompatibleClassChangeError: null
- 等 PHP 这个规则用preg_match_all怎么写
- 等 大佬们,有没有知道Alfresco如何配置LDAP登录呢?
- 等 php的install目录是框架带的吗?
相关问答
最近浏览
a1604914398 LV3
2021年10月27日
watercolor LV5
2020年10月12日
Glovethird
2020年4月12日
暂无贡献等级
wcqpg13 LV2
2019年3月7日
kitefly LV2
2019年1月8日
大葱葱 LV2
2018年11月6日
李瑞涛
2018年11月5日
暂无贡献等级
tracy_lee LV15
2018年10月25日
AliBION LV5
2018年10月14日
sessionbest LV2
2018年9月29日