Für die Beispiele werden folgende Teile benötigt:
Am besten in der lernkube Umgebung mit gestartetem Maven Container.
Im gestarteten Maven Container:
cd /src
git clone https://github.com/mc-b/iot.kafka
mvn clean package
exit
Auf der Git/Bash (ausserhalb des Containers)
cd data/src/iot.kafka
docker build -f Dockerfile.pipe -t misegr/iot-kafka-pipe .
docker build -f Dockerfile.consumer -t misegr/iot-kafka-consumer .
docker build -f Dockerfile.alert -t misegr/iot-kafka-alert .
Auf das IoTKit ist das MQTTPublish Programm zu laden. Vor dem Compilieren sind die Einträge host
und ggf. port
anzupassen. Der host
entspricht der IP-Adresse der VM die mittels lernkube erstellt wurde.
- IoTKit --> MQTT-Protokoll --> MQTT Broker --> MQTT-Kafka-Bridge --> Pipe und CSVConsumer und Alert
kubectl create -f duk/iot/mosquitto.yaml
kubectl create -f duk/kafka
kubectl create -f iot.kafka
In den Entsprechenden Logs der Container stehen die Meldungen drin, z.B.:
logs iot-kafka-pipe