柠檬学院
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 LV22018年9月29日

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

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

相关问答
    最近浏览
    kitefly1月8日
    暂无贡献等级
    大葱葱 LV22018年11月6日
    星星星星
    李瑞涛2018年11月5日
    暂无贡献等级
    tracy_lee LV122018年10月25日
    月亮月亮月亮
    AliBION LV42018年10月14日
    月亮
    sessionbest LV22018年9月29日
    星星星星
    my139977792018年9月28日
    暂无贡献等级
    lryepoch LV22018年9月26日
    星星星星
    萧天宸 LV42018年9月26日
    月亮
    hqbaby LV122018年9月25日
    月亮月亮月亮
    顶部客服微信二维码底部
    >扫描二维码关注最代码为好友扫描二维码关注最代码为好友