docs/archived/v0.23-docs/eventing/sources/apache-camel-source/source_mqtt.yaml

33 lines
918 B
YAML

# Apache Camel MQTT Source
#
# Paho Component documentation: https://camel.apache.org/components/latest/paho-component.html
#
# List of available Apache Camel components: https://camel.apache.org/components/latest/
#
apiVersion: sources.knative.dev/v1alpha1
kind: CamelSource
metadata:
name: camel-mqtt-source
spec:
source:
# To increase throughput, you can (optionally) read using multiple pods in parallel
integration:
replicas: 2
flow:
from:
# Specify here the topic to subscribe to
uri: paho:mytopic
parameters:
# URL of the MQTT source
brokerUrl: tcp://mosquitto:1883
# A unique client ID for the source
clientId: mqtt-knative-bridge
steps:
- log:
message: "Forwarding: ${body}"
sink:
ref:
apiVersion: messaging.knative.dev/v1
kind: InMemoryChannel
name: camel-test