Kafka Streams Examples This repo contains many JUNIT test classes about Kafka Streaming transformations Contents Example Word count example Stateless Branch Filter Inverse Filter FlatMap FlatMapValue Foreach GroupByKey GroupBy Cogroup MapTest MapValuesTest Peek Print SelectKey TableToStream Stateful AggregateTest References Confluent Documentation