-
查看當(dāng)前消費進度(需要消費者在線)
./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --describe
-
重置消費進度(需要消費者離線)
./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --reset-offsets --to-earliest --topic RecordStoreTopic --execute
-
查看Topic的offset饭宾,確認(rèn)修改后的消費進度是否正確
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list fz22:9092 -topic RecordStoreTopic --time -2
kafka 1.1.0重置消費進度
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
- 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來唆铐,“玉大人,你說我怎么就攤上這事奔滑“瘢” “怎么了?”我有些...
- 文/不壞的土叔 我叫張陵朋其,是天一觀的道長王浴。 經(jīng)常有香客問我,道長梅猿,這世上最難降的妖魔是什么氓辣? 我笑而不...
- 正文 為了忘掉前任,我火速辦了婚禮袱蚓,結(jié)果婚禮上钞啸,老公的妹妹穿的比我還像新娘。我一直安慰自己喇潘,他們只是感情好体斩,可當(dāng)我...
- 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著颖低,像睡著了一般絮吵。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上忱屑,一...
- 文/蒼蘭香墨 我猛地睜開眼幔崖,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了渣淤?” 一聲冷哼從身側(cè)響起赏寇,我...
- 正文 年R本政府宣布佛南,位于F島的核電站梗掰,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏嗅回。R本人自食惡果不足惜及穗,卻給世界環(huán)境...
- 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望绵载。 院中可真熱鬧埂陆,春花似錦、人聲如沸娃豹。這莊子的主人今日做“春日...
- 文/蒼蘭香墨 我抬頭看了看天上的太陽培愁。三九已至著摔,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間定续,已是汗流浹背谍咆。 一陣腳步聲響...
推薦閱讀更多精彩內(nèi)容
- Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn)克滴,斷路器逼争,智...
- 大致可以通過上述情況進行排除 1.kafka服務(wù)器問題 查看日志是否有報錯,網(wǎng)絡(luò)訪問問題等劝赔。 2. kafka p...
- Kafka簡介 Kafka是一種分布式的誓焦,基于發(fā)布/訂閱的消息系統(tǒng)。主要設(shè)計目標(biāo)如下: 以時間復(fù)雜度為O(1)的方...
- 本文轉(zhuǎn)載自http://dataunion.org/?p=9307 背景介紹Kafka簡介Kafka是一種分布式的...
- 姓名:周小蓬 16019110037 轉(zhuǎn)載自:http://blog.csdn.net/YChenFeng/art...