Kafka Temperature Analytics

Kafka Streams app to process streaming events from sensors

Architecture

Prerequisite

1. Java 11
2. Docker
3. Confluent Kafka 6.2.0
4. Maven

Getting Started

To run the application, Change PropertyFiles application.properties and equipment.properties accordingly

Build the maven project

mvn clean install  

Run the project

Follow the steps to get output

Produce data in avro format using Datagen to the topics. For Dashboard run the Live Dashboard

To Change Capture

java -cp KafkaTemperatureAnalytics-0.1.jar com.appu.main.EquipmentAvroToJson
java -cp KafkaTemperatureAnalytics-0.1.jar com.appu.main.EquipmentAnalytics

Further Reading

Medium

Demo

Youtube

Alternatives

KafkaTemperatureAnalyticsSpark | KafkaTemperatureAnalyticsFlink