Skip to content

Sample application that demonstrates streaming data processing with Kafka Streams and Spring Framework

Notifications You must be signed in to change notification settings

sergeyevd/spring-kafka-streams-sample

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

1 Commit
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Weather processor application

This is a sample application used in the "Using Kafka Streams with Spring Framework" speech.

It collects weather data from sensors via REST API, sends the data to Kafka and finally send alerts to the standart output of threshold values are reached.

The whole solution consists of 3 parts:

  1. WeatherSensor.py - sample sensor application that can generate mock data or collect real measurements from DHT22 sensor connected to RaspberryPi
  2. "REST API" application - simple Spring Boot microservice that exposes REST API endpoint for collecting weather data sent by WeatherSensor.py, it then forwards the data to a Kafka topic.
  3. "Streams" application - Spring Boot application that uses Spring Cloud Stream Kafka Streams to listen for weather event and applies threshold processing (simply logs alerts to standard output).

About

Sample application that demonstrates streaming data processing with Kafka Streams and Spring Framework

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published