java获取kafka主题列表 原

<!-- kafka -->
		<dependency>
			<groupId>org.apache.kafka</groupId>
			<artifactId>kafka-clients</artifactId>
			<version>0.10.2.1</version>
		</dependency>
		<dependency>
			<groupId>org.apache.kafka</groupId>
			<artifactId>kafka_2.11</artifactId>
			<version>0.10.2.1</version>
		</dependency>

package com.scc.flume.source.kafkasource;

import java.util.Map;
import java.util.Map.Entry;
import java.util.Properties;

import org.apache.kafka.common.security.JaasUtils;

import kafka.admin.AdminUtils;
import kafka.utils.ZkUtils;
import scala.collection.JavaConverters;

public class KafkaSource {

	public static void main(String[] args) {
		ZkUtils zkUtils = ZkUtils.apply("172.16.40.4:2181", 30000, 30000, JaasUtils.isZkSecurityEnabled());
		Map<String, Properties> topics = JavaConverters.mapAsJavaMapConverter(AdminUtils.fetchAllTopicConfigs(zkUtils))
				.asJava();
		for (Entry<String, Properties> entry : topics.entrySet()) {
			String key = entry.getKey();
			Object value = entry.getValue();
			System.out.println(key + ":" + value);
		}
		zkUtils.close();
	}

}

Map<String, List<PartitionInfo>> topics = consumer.listTopics();
			if (null != topics) {
				for (String topic : topics.keySet()) {
					LOGGER.info("get a topic ={}", topic);
					ret.add(topic);
				}
			}