[INLONG-238] Support TubeMQ connector for Apache Spark Streaming

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.5.0
• Component/s: inlong-tubemq
• Labels: pull-request-available
• Assignee: imarch1 zhang
• Reporter: imarch1 zhang
• Created: 17/Jun/20 07:07
• Updated: 28/Jul/21 11:41
• Resolved: 22/Jul/20 09:26

Description

Apache Spark Streaming is a popular real-time streaming computing engine, and MQ is the most important source/sink type for it. The users can use TubeMQ connector to consume/produce messge from/to TubeMQ directly if supported. It can hide the Tube details for Spark Streaming users, and make it easy to understand/use TubeMQ.
 

Issue Links

• links to: GitHub Pull Request #176
• links to: GitHub Pull Request #837