A DSL for processing Kafka data streams in pure Erlang - View it on GitHub