[BAHIR-212] MQTT support to flink connector

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: Flink-1.0
• Component/s: Flink Streaming Connectors
• Labels: features
• Environment: Software
• Assignee: Unassigned
• Reporter: Antonio Miranda
• Created: 18/Jul/19 10:36
• Updated: 12/Mar/21 07:05

Description

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
 

Issue Links

• links to: GitHub Pull Request #100

Sub-Tasks

• add flink MQTT source: Open
• add flink MQTT sink: Open