今天遇到一個問題，由于代碼問題導致了很多kafka訊息入到備用庫，偏移量已經變成了最新；如何將偏移量重設到某個時間點，但消費群組重新去消費一次，是解決問題的關鍵，于是，使用了kafka/bin的sh程式，以下是解決問題的步驟：
- 查看某個組的topic偏移量，這步只是查看，沒什么配置作用，只是作到心中有數，時間戳可以使用在線工具去生成
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 -topic order_new -time 1659087120000
- 直接修改原消費組的topic的偏移量
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group1 --topic order_new --reset-offsets --to-datetime 2022-07-29T18:00:00.000 --execute
你將到得到一個錯誤，這個錯誤是說，本消費組是活動的，你不能修改
- 我們需要棄舊圖新，建立新組group2，并且系結原因的topic，再修改新組的offset偏移量，再把代碼里的消費群組改成新組，就可以了
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic order_new --group group2
- 修改group2對于order_new的偏移量，偏移量對應的時間節點是2022-07-29T18:00:00.000
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group2 --topic order_new --reset-offsets --to-datetime 2022-07-29T18:00:00.000 --execute
- 查看修改后的狀態，也可以通過kafka客戶端去查看
kafka-consumer-groups.sh --describe --group group2 --state --bootstrap-server localhost:9092
作者：倉儲大叔，張占嶺，
榮譽：微軟MVP
QQ：853066980
支付寶掃一掃，為大叔打賞!
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/500725.html
標籤：Java
上一篇：Codeforces CodeTON Round 2 (Div. 1 + Div. 2, Rated, Prizes!) A-D 題解
下一篇：ElasticSearch