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);
- }