agwermann opened a new issue #2690: URL: https://github.com/apache/camel-k/issues/2690
Hi, I am doing some tests with camel-k, Knative and the MQTT broker Mosquito. According to the camel-k documentation, it is possible to create a mqtt-source that will subscribe to a MQTT topic and forward the messages as Cloud Events to the serverless broker. However, I am facing some issues to do that, and I am not able to identify the problem. My testbed is composed by: 1. Knative cluster running on [kind](https://kind.sigs.k8s.io/docs/user/quick-start). 2. Knative broker using [RabbitMQ](https://github.com/knative-sandbox/eventing-rabbitmq/blob/main/broker/README.md). 3. Knative broker trigger and sink processes (bind to RabbitMQ broker). 4. Mosquito MQTT broker deployed to Knative cluster and exposed to outside world. 5. IoT Sensors sending MQTT messages to Kubernetes cluster on exposed port (1883). I am able to publish and subscribe o the MQTT broker from outside the cluster, but it looks the below KameletBinding is not working, since the event is not received by the Rabbitmq trigger/sink. I am able to receive in the Rabbitmq event sink cloud events generated by a PingSource process as per steps described [here](https://github.com/knative-sandbox/eventing-rabbitmq/blob/main/broker/README.md). As far as I understood, [CamelSource was deprecated](https://github.com/nicolaferraro/knative-camel-source-examples/blob/master/04-mqtt.yaml). So far I was not able to use KameletBinding + KNative broker + Cloud Events header filters in the broker pattern as per described in the [link](https://github.com/nicolaferraro/knative-camel-source-examples/blob/master/04-mqtt.yaml#L16). **Questions:** 1. Can someone please share a workable example or indicate what is being done wrong in my scenario? 2. Is it possible to use Knative/camel-k to publish back to mosquitto broker (e.g. mqtt sink). Example: Serverless Broker -> MQTT Mosquitto broker. ``` apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: mqtt-source-binding spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: mqtt-source properties: brokerUrl: "tcp://mosquitto:1883" topic: "mytopic" sink: ref: kind: Broker apiVersion: messaging.knative.dev/v1 name: default ``` **Resources:** - https://github.com/apache/camel-kamelets/blob/main/mqtt-source.kamelet.yaml - https://github.com/nicolaferraro/knative-camel-source-examples/blob/master/04-mqtt.yaml (deprecated) - https://camel.apache.org/camel-kamelets/latest/mqtt-source.html -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
