mqtt.kafka.proxy

mqtt.kafka.proxy

In this guide, you create Kafka topics and use Zilla to mediate MQTT broker messages onto those topics.

Setup

To start the Docker Compose stack defined in the compose.yaml file, use:

docker compose up -d

Using this example

Using mosquitto-cli subscribe to the zilla topic.

docker compose -p zilla-mqtt-kafka-proxy exec -T mosquitto-cli \
    mosquitto_sub --url mqtt://zilla.examples.dev:7183/zilla --debug

output:

Client null sending CONNECT
Client null received CONNACK (0)
Client null sending SUBSCRIBE (Mid: 1, Topic: zilla, QoS: 0, Options: 0x00)
Client null received SUBACK
Subscribed (mid: 1): 0
Client null received PUBLISH (d0, q0, r0, m0, 'zilla', ... (12 bytes))
Hello Zilla!

In a separate session, publish a valid message on the zilla topic.

docker compose -p zilla-mqtt-kafka-proxy exec -T mosquitto-cli \
    mosquitto_pub --url mqtt://zilla.examples.dev:7183/zilla --message 'Hello Zilla!' --debug

output:

Client null sending CONNECT
Client null received CONNACK (0)
Client null sending PUBLISH (d0, q0, r0, m1, 'zilla', ... (12 bytes))
Client null sending DISCONNECT

Teardown

To remove any resources created by the Docker Compose stack, use:

docker compose down