camel-mqtt-source-kafka-connector source configuration

Connector Description: Allows receiving messages from any endpoint that supports the MQTT protocol, such as a message broker.

When using camel-mqtt-source-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:

  <!-- use the same version as your Camel Kafka connector version -->

To use this source connector in Kafka connect you’ll need to set the following connector.class


The camel-mqtt-source source connector supports 3 options, which are listed below.

Name Description Default Priority


Required The topic to subscribe to Example: mytopic.



Required The URL of the broker where to establish the connection Example: tcp://mosquitto:1883.



The client ID to use when connecting to the resource.



The camel-mqtt-source source connector has no converters out of the box.

The camel-mqtt-source source connector has no transforms out of the box.

The camel-mqtt-source source connector has no aggregation strategies out of the box.