kafka操作API（获取topic列表、创建topic、修改topic、删除topic以及消费组的操作等）
实现kafka的管理端操作API步骤如下： 1.添加pom依赖： 2.编写java操作语句： 其中，使用到的”“consumerConfig.getZookeeperConn()”,可以直接使用所使用的kafka对应的zookeeper地址 ...
原文：Kafka Java API操作topic
Kafka官方提供了两个脚本来管理topic，包括topic的增删改查。其中kafka topics.sh负责topic的创建与删除 kafka configs.sh脚本负责topic的修改和查询，但很多用户都更加倾向于使用程序API的方式对topic进行操作。 上一篇文章中提到了如何使用客户端协议 clientprotocol 来创建topic，本文则使用服务器端的Java API对topic ...
2017-03-21 09:43 5 30418 推荐指数：
相关推荐
java api如何获取kafka所有Topic列表,并放置为一个list
kafka内部所有的实现都是通过TopicCommand的main方法,通过java代码调用API，TopicCommand.main(options)的方式只能打印到控制台，不能转换到一个list。 下面讲解下如何转换为list： 1、查看主题（Topic） 【命令方式】：bin ...
Java API获取topic所占磁盘空间(Kafka 1.0.0)
很多用户都有这样的需求：实时监控某个topic各分区在broker上所占的磁盘空间大小总和。Kafka并没有提供直接的脚本工具用于统计这些数据。 如果依然要实现这个需求，一种方法是通过监控JMX指标得到分区当前总的日志大小，然后手动相加所有分区的值得出；另一种方法就是使用1.0.0引入 ...
Kafka系列三 java API操作
使用java API操作kafka 1.pom.xml 2.producer和consumer配置文件 2.1producer.properties 2.2consumer.properties 3.生产者和消费者代码 3.1 ...
kafka--通过python操作topic
修改 topic 的分区数 shiyanlou:bin/ $ ./kafka-topics.sh --zookeeper localhost:2181 --alter --topic mySendTopic --partitions 4WARNING: If partitions ...
Spring Kafka（二）操作Topic以及Kafka Tool 2的使用
1. 为什么要手动创建Topic 我们从到到尾都没有创建过"topic.quick.demo"这个Topic，这是因为KafkaTemplate在发送的时候就已经帮我们完成了创建的操作 ，所以我们不需要主动创建"topic.quick.demo"这个Topic，而是交由 ...
Kafka常用topic操作命令汇总
topic 工具 https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools offset相关 topic相关 consumer-group相关 consumer相关 producer相关 ...