修改kafka topic的offset幾種方法
查詢topic的offset的範圍
用下面命令可以查詢到topic:test broker:suna:9092的offset的最小值：
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list suna:9092 -topic test --time -2
輸出
test:0:1288
查詢offset的最大值：
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list suna:9092 -topic test --time -1
輸出
test:0:7885
從上面的輸出可以看出topic:test只有一個partition:0 offset範圍為:[1288,7885]
設定consumer group的offset
啟動zookeeper client
/zookeeper/bin/zkCli.sh
通過下面命令設定consumer group:testgroup topic:test partition:0的offset為1288:
set /consumers/testgroup/offsets/test/0 1288
注意如果你的kafka設定了zookeeper root，比如為/kafka，那麼命令應該改為：
set /kafka/consumers/testgroup/offsets/test/0 1288
重啟相關的應用程式，就可以從設定的offset開始讀資料了。
手動更新Kafka存在Zookeeper中的偏移量。我們有時候需要手動將某個主題的偏移量設定成某個值，這時候我們就需要更新Zookeeper中的資料了。Kafka內建為我們提供了修改偏移量的類：kafka.tools.UpdateOffsetsInZK，我們可以通過它修改Zookeeper中某個主題的偏移量，具體操作如下：
[[email protected] ~]$ bin/kafka-run-class.sh kafka.tools.UpdateOffsetsInZK
USAGE: kafka.tools.UpdateOffsetsInZK$ [earliest | latest] consumer.properties topic |
在不輸入引數的情況下，我們可以得知kafka.tools.UpdateOffsetsInZK類需要輸入的引數。我們的consumer.properties檔案配置內容如下：
zookeeper.connect=www.iteblog.com:2181
# timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000
#consumer group id
group.id=group
|
這個工具只能把Zookeeper中偏移量設定成earliest或者latest，如下：
[[email protected] ~]$ bin/kafka-run-class.sh kafka.tools.UpdateOffsetsInZK \
earliest config/consumer.properties iteblog
updating partition 0 with new offset: 276022922
updating partition 1 with new offset: 234360148
updating partition 2 with new offset: 157237157
updating partition 3 with new offset: 106968019
updating partition 4 with new offset: 80696130
updating partition 5 with new offset: 317144986
updating partition 6 with new offset: 299182459
updating partition 7 with new offset: 197012246
updating partition 8 with new offset: 230433681
updating partition 9 with new offset: 120971431
updating partition 10 with new offset: 51200673
updated the offset
for 11 partitions
相關推薦
mysql修改時區的幾種方法(轉載自https://www.cnblogs.com/shiqiangqiang/p/8393662.html)
命令 glob 通過 art 查看 lock .html fault 當前 說明： 以下記錄修改mysql時區的幾種方法。 具體： 方法一：通過mysql命令行模式下動態修改 1.1 查看mysql當前時間，當前時區 select curtime(); #或select
修改kafka topic的offset幾種方法
查詢topic的offset的範圍 用下面命令可以查詢到topic:test broker:suna:9092的offset的最小值： bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list suna
[轉] 用javascript修改css偽類的幾種方法
with pseudo com styles javascrip nts lan css偽類 pos 用javascript修改css偽類的幾種方法： Modify pseudo element styles with JavaScript http://pankajpar
centos7 修改網絡卡名的集中幾種方法
centos 7系列預設安裝時 網絡卡名都是隨即的，像ens33 而且每次都有可能不一樣…給我們自動化運維工作帶來了很大的不方面。 現在我測試過 推薦兩種方法給大家 1 .我們在安裝系統時進行 設定核心引數 這種方法最簡單直接。 移動上下方向按鍵 到第一個 然後按 Tab 鍵 輸入 ne
scrapy修改user-agent的幾種方法
方法1： 修改setting.py中的User-Agent # Crawl responsibly by identifying yourself (and your website) on the user-agent USER_AGENT = ‘Hello
修改.NET程式或DLL的幾種方法
http://hi.baidu.com/expertsearch/blog/item/3763489498ffe9027bf48092.html本文目的是回答一個朋友關於修改程式集的留言，都是比較簡單的修改方式，不涉及脫殼等。1: 利用ILASM和ILDASM我們先建立如下測試程式：namespace
iOS中修改狀態列StatusBar狀態和樣式的幾種方法
有時候我們需要把介面中的狀態列隱藏掉，或者在深背景色的時候需要把狀態列的顏色改為白色。 在iOS7之前通常使用如下方式： UIApplication * app = [UIApplication sharedApplication]; app.statusB
LINUX 中修改ip地址的幾種方法
例如node1：eth0:192.168.4.10，eth1:192.168.2.10 1.直接在名令行下面修改 1)修改eth0 [[email protected] ~]# nmcli connection modify eth0 ipv4.metho
線程同步的幾種方法
並且 word 進行 void 等待 輸出結果 每次 wait 無法訪問 用什麽關鍵字修飾同步方法 ? 用synchronized關鍵字修飾同步方法 同步有幾種實現方法,都是什麽?分別是synchronized,wait與notify wait():使一個線程處於等待狀
SQL Server遍歷表的幾種方法
都是 遍歷 lec delet -s rop itl 想要 temp 在數據庫開發過程中，我們經常會碰到要遍歷數據表的情形，一提到遍歷表，我們第一印象可能就想到使用遊標，使用遊標雖然直觀易懂，但是它不符合面向集合操作的原則，而且性能也比面向集合低。當然，從面向集合操作的角
Html中嵌套其他HTML文件的幾種方法（轉）
java mar net rip gin bsp ace wid style 給大家整理了3個方法，一個是HTML的iframe標簽，別兩個是JS引用。比如要在arr.html文件裏引用index.html文件，方法如下。 HTML引用方法： <iframe na
將HTML5封裝成android應用APK文件的幾種方法
android作為下一代的網頁語言，HTML5擁有很多讓人期待已久的新特性。HTML5的優勢之一在於能夠實現跨平臺遊戲編碼移植，現在已經有很多公司在移動 設備上使用HTML5技術。隨著HTML5跨平臺支持的不斷增強和智能手機的迅速普，HTML5技術有著非常好的發展前景，甚至有人預言HTML5將引燃 移動平臺遊
C#多線程的幾種方法
task start invoke 數組 erl method 並行計算 bsp nbsp 1、Theard2、TheardPool 線程池3、Task 在Theard上做了優化和改進，建議使用 .start();4、Task.Factory.Start(method)
Java中創建數組的幾種方法
java false 三種 數組下標 [1] [] 判斷 color str Java中創建數組的幾種方法 public static void main(String[] args) { //創建數組的第一種方法 int[] arr=new int[6]; int
克隆對象的幾種方法
克隆 type sharp class 以及 each pcl 反射 tor 克隆對象在開發過程中經常會遇到，有些時候需要淺克隆，有些時候需要深克隆，具體它們之間有什麽區別，以及實現方式有哪些，在這裏總結一下。 實現深克隆有以下幾種方法。 手動 代碼如下：
windows系統字體安裝使用的幾種方法
windows ps 字體簡易安裝方法：1、打開系統盤的 windows 下的 fonts 文件夾；2、用另一個窗口打開字體存放的文件夾；3、在存放字體的文件夾中選擇要安裝的字體（部分選或全選均可）；4、用鼠標右鍵將所選字體拖到windows 下的 fonts 文件夾上，松開鼠標，在彈出的提示框上選擇
liunx下獲取網卡地址的幾種方法
liunx下獲取網卡地址的幾種方法CentOS Linux release 7.2.1511 (Core)系統獲取網卡ipifconfig em1|awk ‘NR==2 {print $2}‘ifconfig em1|sed -n ‘2p‘|cut -d ‘ ‘ -f 10ifconfig em1|sed -
(轉)Unity3D中移動物體位置的幾種方法
多種方式 移動 2.4 包括 簡介 調用 在外 blank targe 1. 簡介 在unity3d中，有多種方式可以改變物體的坐標，實現移動的目的，其本質是每幀修改物體的position。 2. 通過Transform組件移動物體 Transform 組件
spring mvc獲取絕對路徑的幾種方法
col 文件 結果 ret 項目 tps span ppr etc 1.首先如果是在一個controller方法中，則很簡單，直接用下面語句。 1 @RequestMapping("categoryHome") 2 public ModelAndVie
判斷JS數據類型的幾種方法
object sta 無效 追溯 是否 執行 都是 undefine 代碼 原文轉自http://www.cnblogs.com/onepixel/p/5126046.html！ 說到數據類型，我們先說一下JavaScript 中常見的幾種數據類型： 基本類型：string