Inspired by the Kafka Connector. Tested on Kubernetes cluster running on Raspberry Pi 3s.
To deploy to Kubernetes cluster change the MQTT broker URL in connector.yaml. An then run
kubectl apply -f deployment/kubernetes/connector.yaml
- QoS is currently fixed to 2
- No possibility to configure MQTT credentials
- Error handling and retry mechanisms.
- Content type of request is not set.