专栏首页杂烩java获取kafka主题列表 原

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

}

或者直接使用kafka的api

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

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • nodejs的redis工具类 原

    做一个工具时,起初用到redis,后来发现有更好的解决方案,遂放弃redis,但辛辛苦苦写的code不舍得删,这里记录下

    尚浩宇
  • kafka-eagle1.1.9安装 原

    源码地址https://github.com/smartloli/kafka-eagle

    尚浩宇
  • spring-session配置 原

    同大多数session共享工具一样,通常拿redis作为session存放地,以下为maven依赖

    尚浩宇
  • LeCun辞任FAIR主任回归学术,Facebook并未“变天”

    AI 科技评论消息:1 月 24 日,据 Yann LeCun 在其 Facebook 上确认,他将辞去由他一手创建的 Facebook 人工智能实验室(FAI...

    企鹅号小编
  • Javaweb-案例练习-4-加入购物车的实现过程

    这篇来做一个练习,就是图书详情页面,点击购买按钮,这本书添加到购物中。购物车中主要思想就是采用HashMap来存储数据。

    凯哥Java
  • linux服务器搭建之路8-安装cairo-dock美化桌面

    可能出现不成功,因为不是每个人的nux-dextop都能连上,比如我就一直连接不上。

    锦小年
  • 【Mockplus教程】标尺和参考线

    鼠标左键点住标尺,然后向工作区内部移动,就会出现一根相应方向(横向/纵向)的对齐线。

    奔跑的小鹿
  • 字符串匹配算法之KMP

    需求一:项目结果文件中实验结论可能会存在未知类型、转换错误、空指针、超过索引长度等等。这里是类比需求,用日常开发中常出现的错误类型作为需求,如果要以上结论则判断...

    沁溪源
  • 【Mockplus教程】标尺和参考线

    每个页面都拥有单独的标尺和参考线,可以用于辅助组件的对齐以及尺寸调整。 1. 使用标尺 新建页面之后,在主菜单中选择“显示标尺”即可看到工作区左边和上边显...

    奔跑的小鹿
  • 还在为找相似文献头疼?还在为找推荐审稿人头疼?

    比如说,有的时候,开会看到别人的研究,很感兴趣但是手速不够快只拍到了一句话,需要找全文。

    百味科研芝士

扫码关注云+社区

领取腾讯云代金券