Kafka獲取訂閱某topic的所有consumer group【客戶端版】
之前寫過如何用服務器端的API代碼來獲取訂閱某topic的所有consumer group，參見這里。使用服務器端的API需要用到kafka.admin.AdminClient類，但是這個類在0.11.0.0版本已經被標記為不推薦使用了，故目前最合適的方式還是通過客戶端API ...
原文：查詢訂閱某topic的所有consumer group(Java API)
在網上碰到的問題，想了下使用現有的API還是可以實現的。 首先，需要引入Kafka服務器端代碼，比如加入Kafka . . 依賴： Maven lt dependency gt lt groupId gt org.apache.kafka lt groupId gt lt artifactId gt kafka . lt artifactId gt lt version gt . . lt ver ...
2017-11-14 11:48 3 1393 推薦指數：
相關推薦
Kafka Java consumer動態修改topic訂閱
前段時間在Kafka QQ群中有人問及此事——關於Java consumer如何動態修改topic訂閱的問題。仔細一想才發現這的確是個好問題，因為如果簡單地在另一個線程中直接持有consumer實例然后調用subscribe進行修改，consumer端必然會拋出異常 ...
Kafka查看topic、consumer group狀態命令
、replica信息 3，查看consumer group列表，使用--list參數 查看consumer gr ...
Kafka查看topic、consumer group狀態命令
最近工作中遇到需要使用kafka的場景，測試消費程序啟動后，要莫名的過幾十秒乃至幾分鍾才能成功獲取到到topic的partition和offset，而后開始消費數據，於是學習了一下查看kafka broker里topic和consumer group狀態的相關命令，這里記錄一下。 命令參考 ...
Kafka查看topic、consumer group狀態命令
最近工作中遇到需要使用kafka的場景，測試消費程序啟動后，要莫名的過幾十秒乃至幾分鍾才能成功獲取到到topic的partition和offset，而后開始消費數據，於是學習了一下查看kafka broker里topic和consumer group狀態的相關命令，這里記錄一下。 命令參考 ...
Java API獲取consumer group最新提交位移的時間
碰到了有人問起這個問題，目前java consumer沒有利用OffsetAndMetadata中的metadata字段記錄提交的時間，故直接通過java consumer來查詢是不行，我們需要直接讀取__consumer_offsets，代碼如下: public static long ...
java api如何獲取kafka所有Topic列表,並放置為一個list
kafka內部所有的實現都是通過TopicCommand的main方法,通過java代碼調用API，TopicCommand.main(options)的方式只能打印到控制台，不能轉換到一個list。 下面講解下如何轉換為list： 1、查看主題（Topic） 【命令方式】：bin ...
Kafka Java API操作topic
Kafka官方提供了兩個腳本來管理topic，包括topic的增刪改查。其中kafka-topics.sh負責topic的創建與刪除；kafka-configs.sh腳本負責topic的修改和查詢，但很多用戶都更加傾向於使用程序API的方式對topic進行操作 ...