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
Mqtt5 Source Kamelet Description
Authentication methods
This Kamelet connects to Mqtt5 using appropriate authentication mechanisms:
-
Service-specific authentication methods
-
API keys, tokens, or credential-based authentication
-
Connection configuration
Configuration
The Kamelet requires connection parameters specific to Mqtt5:
-
Service connection details
-
Authentication credentials
-
Query or consumption parameters
Usage example
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: mqtt5-source-binding
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: mqtt5-source
properties:
# Add service-specific properties here
sink:
ref:
kind: Service
apiVersion: v1
name: my-service