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 清空列表所有元素 ...