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.
• Not Looking at Facebook: Implementation of a streaming pipeline for notifying users when they aren't looking at Facebook.