MQTT Source () reads streaming data from an MQTT message queue.
It is typically used for ingesting real-time data from IoT devices, sensors, or event-driven systems that publish messages using the MQTT protocol.

The source continuously subscribes to a specified MQTT topic and emits incoming messages as streaming records.

Parameters of MQTT Source

• URL
  MQTT broker URL
  Example formats:
  • cp://localhost:1883
  • ssl://broker.example.com:8883
• User Name
  User name for MQTT broker authentication
  Optional if the broker allows anonymous access
• Password
  Password for MQTT broker authentication
  Optional if authentication is not required
• Topic
  MQTT topic name to subscribe to
  Supports standard MQTT topic syntax
  Example:
  • sensor/temperature
  • iot/device/+/status

Supported Engines

Map Reduce	Spark 1.x RDD	Spark 2.x RDD	Spark 2.x Dataset	Apache Beam 2.29.0 Batch	Apache Beam 2.29.0 Streaming	Apache Flink 1.12.0 Batch	Apache Flink 1.12.0 Streaming	Apache Tez 0.9.1