A library for writing and reading data from MQTT Servers using Flink SQL Streaming (or Structured streaming).
