kafka操作API（获取topic列表、创建topic、修改topic、删除topic以及消费组的操作等）
实现kafka的管理端操作API步骤如下： 1.添加pom依赖： 2.编写java操作语句： 其中，使用到的”“consumerConfig.getZookeeperConn()”,可以直接使用所使用的kafka对应的zookeeper地址 ...
原文：java api如何获取kafka所有Topic列表,并放置为一个list
kafka内部所有的实现都是通过TopicCommand的main方法,通过java代码调用API，TopicCommand.main options 的方式只能打印到控制台，不能转换到一个list。 下面讲解下如何转换为list： 查看主题 Topic 命令方式 ：bin kafka topics.sh list zookeeper . . . : kafka JAVA API方式 ： ...
2016-03-07 19:06 1 6158 推荐指数：
相关推荐
Java API获取topic所占磁盘空间(Kafka 1.0.0)
很多用户都有这样的需求：实时监控某个topic各分区在broker上所占的磁盘空间大小总和。Kafka并没有提供直接的脚本工具用于统计这些数据。 如果依然要实现这个需求，一种方法是通过监控JMX指标得到分区当前总的日志大小，然后手动相加所有分区的值得出；另一种方法就是使用1.0.0引入 ...
Kafka Java API操作topic
Kafka官方提供了两个脚本来管理topic，包括topic的增删改查。其中kafka-topics.sh负责topic的创建与删除；kafka-configs.sh脚本负责topic的修改和查询，但很多用户都更加倾向于使用程序API的方式对topic进行操作 ...
kafka删除一个topic
前言 当我们在shell中执行topic删除命令的时候` kafka-topics --delete --topic xxxx --zookeeper xxx`，会显示，xxxx已经被标记为删除。然后过了很久你再查看topic列表，发现那个topic依然被标记删除，显然删除没有真正执行。下面 ...
查询订阅某topic的所有consumer group(Java API)
在网上碰到的问题，想了下使用现有的API还是可以实现的。 首先，需要引入Kafka服务器端代码，比如加入Kafka 1.0.0依赖： Maven <dependency> <groupId>org.apache.kafka</groupId> < ...
kafka java动态获取topic并动态创建消费者
1.获取所有topic package com.example.demo; import java.io.IOException; import java.util.List; import org.apache.zookeeper.KeeperException; import ...
Kafka创建Topic时如何将分区放置到不同的Broker中
熟悉 Kafka的同学肯定知道，每个主题有多个分区，每个分区会存在多个副本，本文今天要讨论的是这些副本是怎么样放置在 Kafka集群的 Broker 中的。 大家可能在网上看过这方面的知识，网上对这方面的知识是千变一律，都是如下说明的： 为了更好的做负载均衡，Kafka尽量将所有 ...
java list 清空列表所有元素
Java list 清空列表所有元素 ...