This repository is a sample of using Akka Alpakka extension with Kafka broker to produce and consume data with handling back-pressure.