ivicar的gravatar头像
ivicar2018-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的gravatar头像
sessionbest LV29月29日

MQTT 与 Kafka 是完全不同的两个东西, MQTT 是协议,是一个技术标准,而 Kafka 是已经实现的开源流处理平台.

kafka可以mqtt协议做..但mqtt apollo是另一种自有协议...完全不是一个东西.无法通讯!

相关问答
    最近浏览
    大葱葱 LV211月6日
    星星星星
    李瑞涛11月5日
    暂无贡献等级
    tracy_lee LV1210月25日
    月亮月亮月亮
    AliBION LV410月14日
    月亮
    sessionbest LV29月29日
    星星星星
    my139977799月28日
    暂无贡献等级
    lryepoch LV29月26日
    星星星星
    萧天宸 LV49月26日
    月亮
    hqbaby LV119月25日
    月亮月亮星星星星星星
    1529860026 LV189月25日
    太阳星星星星
    顶部客服微信二维码底部
    >扫描二维码关注最代码为好友扫描二维码关注最代码为好友