如何重置用於消費卡夫卡消息的偏移量？

我從卡夫卡隊列中消耗了一些消息，現在我想再次使用它們（只需從頭開始獲取所有數據）。如何重置Scala中的偏移量或使用Kafka Rest Proxy？我目前使用"auto.offset.reset": "smallest"：如何重置用於消費卡夫卡消息的偏移量？

curl -X POST -H "Content-Type: application/vnd.kafka.v1+json" \ 
     --data '{"format": "json", "auto.offset.reset": "smallest"}' \ 
     XXX.XX.XXX.XXX:9092/consumers/test

請注意，我不感興趣的解決方案

來源

2017-01-04 Dinosaurius

你使用什麼客戶端庫來消費這些消息？你能粘貼代碼嗎？另外 - 對解決方案_不感興趣？ – Dani

最後PARAM中的URL 組ID。卡夫卡商店承諾每個組別的抵消金額。因此，更改組標識應該足夠了（.../consumers/newGroupId）。

來源

2017-01-04 17:18:11 Natalia

如何重置用於消費卡夫卡消息的偏移量？

回答

相關問題