Strimzi

Term 2 · Jun-Aug · 1 project

• Proof of Concept of an MQTT to Apache Kafka bridge for producing messages

  LFX Mentorship · Listed in the official cohort

  @ppatiernoSource IssueLFX portal

  A really common use case we have been seeing is about enabling an IoT scenario with MQTT based devices and using an Apache Kafka cluster as the events and storage platform running on Kubernetes via Strimzi. In order to do that, there is the need to map the MQTT protocol to the custom Apache Kafka one and bridge from one to the other. This project idea is about designing such a mapping and developing a pure Netty based MQTT server component (not a full MQTT broker) able to accept MQTT client connections and handling the corresponding communication based on the MQTT 3.1.1 specification. Finally, developing the Kafka producer part to get messages from MQTT clients and sending them to an Apache Kafka cluster.

  • Java
  • Apache Kafka (not mandatory but to be learned)
  • MQTT protocol (not mandatory but to be learned)