Repository files navigation

This repository provides the source code for our blog post onMedium.

It includes an example implementation of a Kafka Streams application that provides a key-value query interface to the messages of a key-partitioned Kafka topic.

Additionally, a Dockerfile and a Kubernetes deployment specification demonstrate how the application can be easily deployed to a Kubernetes Cluster.

Compile the project using Maven:

mvn package

Start one or more instances of the Kafka Streams application:

./streams-processor                         \    --topic messages                        \    --streams-props                         \        bootstrap.servers=localhost:9092    \        num.standby.replicas=1              \    --application-id my-streams-processor   \    --hostname localhost