You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "jiang7chengzitc (Jira)" <ji...@apache.org> on 2020/11/18 14:22:00 UTC
[jira] [Comment Edited] (BAHIR-212) MQTT support to flink connector
[ https://issues.apache.org/jira/browse/BAHIR-212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234663#comment-17234663 ]
jiang7chengzitc edited comment on BAHIR-212 at 11/18/20, 2:21 PM:
------------------------------------------------------------------
hello,
In fact, in the field of IOT, MQTT is a protocol that used highly frequently, and recently I am implementing the MQTT connector (including streaming source and sink) to extend flink, now it have been applied to the actual production environment. so I want to contribute this connector to Apache Bahir.[~lresende]
was (Author: jiang7chengzitc):
hello,
In fact, in the field of IOT, MQTT is a protocol that used highly frequently, and recently I am implementing the MQTT connector (including streaming source and sink) to extend flink, now it have been applied to the actual production environment. so I want to contribute this connector to Apache Bahir.
> MQTT support to flink connector
> -------------------------------
>
> Key: BAHIR-212
> URL: https://issues.apache.org/jira/browse/BAHIR-212
> Project: Bahir
> Issue Type: Improvement
> Components: Flink Streaming Connectors
> Affects Versions: Flink-1.0
> Environment: Software
> Reporter: Antonio Miranda
> Priority: Minor
> Labels: features
>
> Hello,
> I'm working with Apache Flink, and I would like to have a Streaming connector for the MQTT protocol. The problem now is that the library that you use of activemq-client, does not have support for MQTT. I found on the Internet the library, whose structure is similar to activemq-client, but with support for MQTT ([https://github.com/apache/activemq/blob/master/activemq-mqtt]).
> Would it be possible to update the connector to support MQTT?
> Thank you
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)