# JAVA: Create Kafka Consumer

Published 2022-12-03

This tutorial explains to you how to create a Kafka consumer using Java. This tutorial has an example as well.

A nice job to do is to read messages from a Kafka topic. In this tutorial, I will explain to you how to read a message from a Kafka topic in Java.

First of all you must install a Kafka server in order to test it. For this example you don't need to install a Kafka cluster.

So, on my environment you have some prerequisites in order to test the Java code below.


  1. From the machine you run the Java client you must see the private Kafka server sockets (hostname:IP)

  2. You must have a Kafka topic named my-topic10

-- List all topics (prints only topic names)

kafka-topics.sh --list --zookeeper zookeeper1:2181/kafka

And now look at the code.

In pom.xml we must have :


And the class which create the Kafka consumer is like this :