mqtt Binding

Defines a binding with mqtt protocol support, with server behavior.

server

Full config

The server kind mqtt binding decodes the MQTT protocol on the inbound network stream, producing higher level application streams for each publish or subscribe MQTT topic. The session state is also described by a higher level application stream.

Conditional routes based on the MQTT topic name are used to route these application streams to an exit binding.

mqtt_server:
  type: mqtt
  kind: server
  options:
    authorization:
      my_jwt_guard:
        credentials:
          connect:
            username: Bearer {credentials}
    versions:
      - v5
      - v3.1.1
  routes:
    - when:
        - session:
            - client-id: "*"
        - publish:
            - topic: command/one
            - topic: command/two
        - subscribe:
            - topic: reply
  exit: mqtt_kafka_proxy

client

Full config

The client kind mqtt binding encodes the MQTT protocol to the outbound network stream.

mqtt_client:
  type: mqtt
  kind: client
  exit: mqtt_client_tcp