Spark based implementation of the Topological Mapper algorithm
Scala Library for Unit-Testing Processing Topologies in Kafka Streams