Set of small KafkaStreams demos/tests written in Scala 2.12, using Kafka 2.1.1
- Kafka Streams Introduction
- Example 1 : Straight through processing / How to test Kafka Streams
- Stateless Transformations
- Stateful Transformations
- Aggregating
- Joining
- Windowing
- Applying processors and transformers (Processor API integration)
- Custom Serdes
- Interactive Queries