[ https://issues.apache.org/jira/browse/BAHIR-212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234663#comment-17234663 ]
jiang7chengzitc commented on BAHIR-212: --------------------------------------- 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)