This repository contains examples of use cases (ranging from trivial to somewhat complex) of Kafka Streams.
Each example is in it's own directory. The repository contains the following examples:
- Exclamation: Trivial example that reads from the console consumer and appends two exclamation points.
- Exclamation Advanced: Slightly more complicated version of Exclamation that "alerts" on highly exclamated messages.
- Hopping Windows: Example demonstrating the behavior of hopping windows by counting the elements on a single key.
- Tumbling Windows: Example demonstrating the behavior of tumbling windows by counting the elements on a single key.
- Processor: Example demonstrating the processor API, state stores, and custom serializers.
- Instrumented Processor: A stripped down version of the processor example that logs the values in the state store - designed to run in two nodes (or just two terminals) to show what happens under failover conditions.
- Not Looking at Facebook: Implementation of a streaming pipeline for notifying users when they aren't looking at Facebook.
- KTable: Literally a KTable.
- Windowed Delay: Demonstration of event-time ordering.