MQTT 5 Source
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Stable"
Allows receiving messages from any endpoint that supports the MQTT v5 protocol, such as a message broker.
Configuration Options
The following table summarizes the configuration options available for the mqtt5-source
Kamelet:
Property | Name | Description | Type | Default | Example |
---|---|---|---|---|---|
Broker URL | Required The URL of the broker where to establish the connection. | string | tcp://mosquitto:1883 | ||
Topic | Required The topic to subscribe to. | string | mytopic | ||
Client ID | The client ID to use when connecting to the resource. | string | mqtt-source | ||
Password | Password to use when connecting to the MQTT v5 compliant broker. | string | |||
Username | Username to use when connecting to the MQTT v5 compliant broker. | string |
Dependencies
At runtime, the mqtt5-source
Kamelet relies upon the presence of the following dependencies:
-
camel:paho-mqtt5
-
camel:kamelet
Camel JBang usage
Prerequisites
-
You’ve installed JBang.
-
You have executed the following command:
jbang app install camel@apache/camel
Supposing you have a file named route.yaml with this content:
- route:
from:
uri: "kamelet:mqtt5-source"
parameters:
.
.
.
steps:
- to:
uri: "kamelet:log-sink"
You can now run it directly through the following command
camel run route.yaml