Storm-mqtt is a sample Spout implementation of MQTT.
This receive messages from MQTT broker as a String, store in the queue and emit to the Storm Bolt.
Eclipse Public License - Version 1.0
shirou/storm-mqtt
storm-mqtt is a sample implementation of Storm spout which can receive MQTT messages.
Java