/bigiot

A data platform implementation for remote monitoring systems using asynchronous messaging

Primary LanguageScala

Big IoT

Big IoT Architecture

Infrastructure

docker-compose up -d 
...
Creating network "bigiot_default" with the default driver
Creating zk         ... done
Creating prometheus ... done
Creating grafana    ... done
Creating kafka      ... done
Creating emqx          ... done
Creating kafka-manager ... done

Kafka adapter

Proxy messages between EMQ X Broker and the Kafka Broker.

Environment variables configuration

CLIENT_ID=mqtt-proxy
MQTT_HOST=localhost
MQTT_PORT=1883
KAFKA_HOST=localhost
KAFKA_PORT=9092
TOPICS_IN=sensor-in-1
TOPICS_OUT=sensor-out-1