Here is a repository with all the ways of communicatuion with a Kafka cluster using Java and Spring framework.