Linux就该这么学
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();
    }
所有回答列表(0)
相关问答
    最近浏览
    1529860026 LV171小时前
    太阳星星
    心印语 LV96小时前
    月亮月亮星星
    最代码官方 LV137昨天
    皇冠皇冠月亮月亮星星
    hgx378378 LV2前天
    星星星星
    lipiao1211 LV139月21日
    月亮月亮月亮星星
    forehawk LV29月19日
    星星星星
    aadada LV29月18日
    星星星星
    搬砖运代码 LV79月18日
    月亮星星星星星星
    Jamen1996 LV89月17日
    月亮月亮
    temptation LV169月17日
    太阳
    顶部客服微信二维码底部
    >扫描二维码关注最代码为好友扫描二维码关注最代码为好友