In this tutorial I will show you how to list all topics in Kafka. Before you begin you will need Maven/Eclipse all setup and a project ready to go. Also you should go through this tutorial to setup the consumer.
Imports
import java.util.Map; import java.util.List; import org.apache.kafka.common.PartitionInfo;
Consumer List Topics
Map<String, List> listTopics = consumer.listTopics(); System.out.println("list of topic size :" + listTopics.size()); for (String topic : listTopics.keySet()) { System.out.println("topic name :" + topic); }