GitHunt
AB

abhirockzz/kafka-streams-interactive-queries

Interactive Queries in Kafka Streams

Practical example for Interactive Queries feature in Kafka Streams. It covers the DSL API and how the state store information was exposed via a REST service.

For details check this blog

Everything is setup using Docker including Kafka, Zookeeper, the stream processing services as well as the producer app

Here are the key components

  • Metrics producer service - pushes machine metrics (simulated) to Kafka
  • Average Processor service - calculates the average of the stream of generated metrics and exposes REST APIs to query them

Languages

Java92.3%Shell6.8%Dockerfile1.0%
Created December 12, 2018
Updated December 11, 2023
abhirockzz/kafka-streams-interactive-queries | GitHunt