Waterstream - Fleet Demo
Waterstream
Waterstream is a fully fledged MQTT broker leveraging Kafka as its only storage and distribution engine.
Every MQTT message sent by a device is immediately available on Kafka topics without the need of any 'man in the middle' connector. Likewise, devices can instantly receive produced messages on Kafka by subscribing to MQTT topics. Waterstream instances are stateless and therefore easy to scale out. This makes of Waterstream a light platform guaranteeing better throughput, reduced latency between Kafka and devices as well as less operational effort.
The Fleet Demo
In this demo, we simulate hundreds of trucks driving around Italy, you can see 20 of them on the map.
To follow one truck in its route, just click on its label. Sending MQTT messages to the Waterstream, each truck continuously communicates its current position, the next way-point and the speed.
No man in the middle
There's no Kafka connector or other integration technology between Waterstream and Apache Kafka. As soon messages are received by Waterstream, they are available in Apache Kafka topics.
This allows to integrate quickly an IoT platform with operational systems or the data analytics without any other system in the middle.
Waterstream allows bidirectional communication. Data written into topics can be pushed to devices.
Fleet directions statistics
Hence MQTT messages are stored directly in Kafka, you can aggregate them with any streaming technology.
Above we built a real time graph that shows where trucks are headed using current position and waypoint. Graph data is processed by a Flink job that aggregates MQTT messages saved on a Kafka topic.
Do you want to know more?
Visit Waterstream product site at https://waterstream.io/ and learn how you can combine MQTT with Kafka, the standard de-facto streaming platform.
Info
Want to know more about Waterstream? Check out https://waterstream.io/.