Create the camel Integration for the incoming parcels.
To do so, connect to the OpenShift console, select the namespace of your team and click the + button in the top-right corner. Then, copy and paste the following content.
apiVersion: camel.apache.org/v1
kind: Integration
metadata:
name: kafkaintegration-in
spec:
sources:
- content: |
from("paho:esp8266-in?brokerUrl=tcp://mqtt-mqtt-0-svc:1883&userName=admin&password=public")
.setHeader("key").simple("${bodyAs(String)}")
.convertBodyTo(String.class)
.setBody({ e -> [ parcelNumber: e.in.body, timestamp: new Date().getTime() ] })
.marshal().json()
//.to("log:info")
.to("kamelet:kafka-sink-scram?bootstrapServers=warehouse-kafka-bootstrap:9092&user=camel&password=s3cr3t&topic=warehouse-in")
name: mqtt-kafka.groovy
traits: {}