Simple Way to Implement Kafka with Java – Source Code on GitHub