[BAHIR-252] add flink MQTT source

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: Flink-1.0, Flink-1.1.0
• Fix Version/s: Flink-1.2.0
• Component/s: Flink Streaming Connectors
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Ruguo Yu
• Created: 19/Nov/20 00:05
• Updated: 06/Oct/22 15:45

Description

support flink mqtt streaming source in DataStream API and SQL&Table API, through mqtt parameter clientid, cleansession, qos1, persistent and flink checkpoint guarantee at least once.