The producer and consumer components in this case are your own implementations of kafka-console-producer.sh and kafka-console-consumer.sh. Let’s start by creating a Producer.java class.