A library for writing and reading data from MQTT Servers using Flink SQL Streaming (or Structured streaming).
Scala versions:
2.12
Latest version
[](https://index.scala-lang.org/kevin4936/kevin-flink-connector-mqtt3/kevin-flink-connector-mqtt3)
JVM badge
[](https://index.scala-lang.org/kevin4936/kevin-flink-connector-mqtt3/kevin-flink-connector-mqtt3)