Interactive script

You can run prozzie config setup mqtt to interactively configure one mqtt kafka connector. You will be asked for the next variables, that can’t have any default:

mqtt__server_uris

MQTT brokers

mqtt__topic

MQTT Topics to consume

kafka__topic

Topic to produce MQTT consumed messages

However, there are some others “hidden” variables that configure connector. They will be output at the end of interactive setup, and you can reuse them following the Advanced configuration.

Advanced configuration

To configure MQTT you can use kcli tool.

• mqtt.properties

name=mqtt
connector.class=com.evokly.kafka.connect.mqtt.MqttSourceConnector
tasks.max=1
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter

#Settings
kafka.topic=mqtt
mqtt.client_id=my-id
mqtt.clean_session=true
mqtt.connection_timeout=30
mqtt.keep_alive_interval=60
mqtt.server_uris=tcp://localhost:1883
mqtt.topic=mqtttopic/1
mqtt.qos=1
message_processor_class=com.evokly.kafka.connect.mqtt.sample.StringProcessor

You need to configure a mqtt.properties file with your properties:

mqtt.server_uris

The MQTT brokers.

mqtt.topic

The MQTT topics to subcribe.

kafka.topic

The Kafka topic to send the messages.

When you configure the mqtt.properties you need to create the connector:

prozzie kcli create mqtt-connector < mqtt.properties

You can check that messages are properly delivered using prozzie kafka consume <your-mqtt-topic>