[BAHIR-89] New API for subscribing from a list of MQTT topics and Return tuple of <Topic,Message> as output

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: Not Applicable
• Fix Version/s: Spark-2.1.1
• Component/s: Spark Streaming Connectors
• Labels: MQTT SPARK
• Environment: Spark Streaming MQTT Connector
• Flags: Important
• Assignee: Anntinu Josy
• Reporter: Anntinu Josy
• Created: 18/Feb/17 07:25
• Updated: 05/Apr/17 23:48
• Resolved: 23/Mar/17 21:51

Description

I am working in IoT Project. As part of MQTT-Kafka bridge program development I used Bahir. I feel that it will be a good feature to prove a new API to support a list of MQTT topic as input and output as a tuple of <Topic, Message>. This will be useful to reduce resource usage in case of multiple topic subscription. I had developed this feature a like to integrate

Issue Links

• links to: GitHub Pull Request #37