[
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/19/20, 2:56 AM:
------------------------------------------------------------------
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'd like to work on it and contribute MQTT connector to Apache Bahir. Could
someone kindly assign this to me?[~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.[~lresende]
> 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)
