A pub-sub framework built on Kafka - View it on GitHub