消息服務DMS使用實踐 - 如何重置消費組位點

通過消費組A開始消費隊列中的消息,消費到中途時由於故障導致已消費的消息在客戶端未保存,所以需要重新再消費一遍,但是由於Kafka內部機制的原因已消費成功的消息無法再次消費,可怎辦呢? 終於在幫助中找到如下內容,可以解決我的問題: 如果想跳過某些未消費的消息,或者想重新消費隊列中的已消費的消息,或者只想消費某個時間點之後的消息(這些消息不論之前是否消費過),那麼可以通過「消費重置」功能實現選擇性跳過
相關文章
相關標籤/搜索