This is a project to track a stream of data generated by temperature sensors to pass throughout a whole IoT platform consisting of three layers.
This layer talks direclty with the hardware -- in this case: Raspberry Pi with a temp. sensor
the application here is either a python script "dummy_generator" that simulates the hardware or "temp.py" which a script used on the Pi to get the values.
This layer has a java application. The application builds two connectors:
- Kafka-Flink connector --- demonstrated in 2 classes.
- Kafka-Flink-Elasticsearch --- extends the flow by connecting the stream to an Elastic Search node.
Web services to get the data from the ES cluster.