.. _mqtt-source-connector-quickstart:

*********************************************************************
Example: Configure MQTT Source Connector for Eclipse Mosquitto Broker
*********************************************************************

The MQTT source connector is used to receive messages from MQTT brokers, and write them into a Kafka topic. This example demonstrates how to configure a MQTT source connector for the Eclipse Mosquitto broker.

.. _mqtt-source-connector-quickstart-preliminaries:

.. include:: ../includes/mqtt_connector_quickstart_preliminaries.rst

.. _mqtt-source-connector-quickstart-sink-connector:

Configure Source Connector  
--------------------------

#. Create a configuration file named ``mqtt-source-config.json`` with the following contents.

   .. codewithvars:: bash
     :emphasize-lines: 10,11,14

     {
          "name": "source-mqtt",
          "config": {
              "connector.class": "io.confluent.connect.mqtt.MqttSourceConnector",
              "tasks.max": "1",
              "mqtt.server.uri": "tcp://127.0.0.1:1881",
              "mqtt.topics":"hello",
              "kafka.topic":"mqtt-source-1",
              "mqtt.qos": "2",
              "mqtt.username": " Omit if Mqtt broker supports anonymous mode ",
              "mqtt.password": " Omit if Mqtt broker supports anonymous mode ",
              "confluent.topic.bootstrap.servers": "kafka:9092",
              "confluent.topic.replication.factor": "1",
              "confluent.license": " Omit to enable trial mode "
          }
      }

#. Run this command to start the MQTT source connector.

   .. include:: ../../../includes/confluent-local-consume-limit.rst

   .. codewithvars:: bash

      |confluent_load| source-mqtt|dash| -d source-mqtt-config.json

   Your output should resemble:

   .. codewithvars:: bash

      {
          "name": "source-mqtt",
          "config": {
              "connector.class": "io.confluent.connect.mqtt.MqttSourceConnector",
              "tasks.max": "1",
              "mqtt.server.uri": "tcp://127.0.0.1:1881",
              "mqtt.topics":"hello",
              "kafka.topic":"mqtt-source-1",
              "mqtt.qos": "2",
              "mqtt.username": " ### ",
              "mqtt.password": " [hidden] ",
              "confluent.topic.bootstrap.servers": "kafka:9092",
              "confluent.license": " ### ",
              "confluent.topic.replication.factor": "1"
          }
          "tasks": [],
          "type": null
      }