Here is the complete example of Kafka Streams Session Window example. Application produces number of events grouped by key arrived during session window expressed in milliseconds.
All application configuration is done either via arguments or via environment variables.
Sample docker-compose for Kafka single-node cluster and Kafka multi-node cluster is provided for development/testing purposes.
- Java 8+
- Maven 3.6+
- docker-compose 1.23+
- Docker