Source Code for Application Integration With Kafka Blog - View it on GitHub