Kafka Pub/Sub for the Watermill project. - View it on GitHub