mqtt Binding
BindingServer
mqtt Binding
Defines a binding with mqtt
protocol support, with server
behavior.
server
The server
kind mqtt
binding decodes the MQTT protocol on the inbound network stream, producing higher level application streams for each publish
or subscribe
topic
. The session
state is also described by a higher level application stream.
Conditional routes based on the 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
The client
kind mqtt
binding encodes the MQTT protocol to the outbound network stream.
mqtt_client:
type: mqtt
kind: client
exit: mqtt_client_tcp