首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >java获取kafka主题列表 原

java获取kafka主题列表 原

作者头像
尚浩宇
发布于 2018-08-17 03:06:30
发布于 2018-08-17 03:06:30
2.7K00
代码可运行
举报
文章被收录于专栏:杂烩杂烩
运行总次数:0
代码可运行

首先引入依赖

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
<!-- 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>

然后代码

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
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();
	}

}

或者直接使用kafka的api

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
Map<String, List<PartitionInfo>> topics = consumer.listTopics();
			if (null != topics) {
				for (String topic : topics.keySet()) {
					LOGGER.info("get a topic ={}", topic);
					ret.add(topic);
				}
			}
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2017/12/18 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
本文部分代码块支持一键运行,欢迎体验
本文部分代码块支持一键运行,欢迎体验