IoT und Kafka Beispiele

Für die Beispiele werden folgende Teile benötigt:

• IoTKit V3
• lernkube Umgebung

Builden

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.

Funktionsweise

• IoTKit --> MQTT-Protokoll --> MQTT Broker --> MQTT-Kafka-Bridge --> Pipe und CSVConsumer und Alert

Starten

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