通過消費組a開始消費佇列中的訊息，消費到中途時由於故障導致已消費的訊息在客戶端未儲存，所以需要重新再消費一遍，但是由於kafka內部機制的原因已消費成功的訊息無法再次消費，可怎辦呢？
終於在幫助中找到如下內容，可以解決我的問題：
如果想跳過某些未消費的訊息，或者想重新消費佇列中的已消費的訊息，或者只想消費某個時間點之後的訊息（這些訊息不論之前是否消費過），那麼可以通過「消費重置」功能實現選擇性跳過或者重新消費。
消費重置支援以下三種場景：
操作步驟
登入管理控制台。
在管理控制台左上角單擊
單擊頁面上方的「服務列表」，選擇「應用服務 > 分布式訊息服務」，進入分布式訊息服務資訊頁面。
單擊左側選單欄的「佇列管理」，進入「佇列管理」頁面。
單擊指定佇列的名稱，顯示佇列詳情。
選擇「消費組」，顯示消費組列表。
單擊消費組後的「更多」，選擇「消費重置」，進入「消費重置」頁面。
選擇「重置位置」、是否強制重置，單擊「確定」，執行重置消費位置。
表1消費訊息引數說明
引數說明重置位置
預設為從佇列頭端消費訊息。
自定義時間
當重置位置選擇「自定義時間消費訊息」時，需要設定自定義時間，並且只能選擇72小時範圍內的時間。
強制重置
關閉：重置時如果消費組正在消費訊息，則重置會失敗。
開啟：強制進行消費重置，如果消費組正在消費訊息，則可能會消費失敗。
預設為關閉。
分布式訊息服務DMS如何實現死信訊息的消費
本文部分內容節選自華為雲幫助中心的分布式訊息服務 dms 服務的產品介紹 死信訊息是什麼 死信訊息是指無法被正常消費的訊息。分布式訊息服務dms支援對訊息進行異常處理。當訊息進行多次重複消費仍然失敗後，dms會將該條訊息轉存到死信佇列中，有效期為72小時，使用者可以根據需要對死信訊息進行重新消費。消...
如何通過資料管理服務DMS登入MongoDB資料庫
登入mongodb資料庫有兩種常用方法，本文介紹通過資料管理服務dms登入mongodb資料庫，更便捷地對mongodb資料庫進行管理。注意事項 通過dms登入mongodb例項的資料庫時，須使用mongodb例項的內網連線位址，暫不支援公網連線位址。準備工作 將下表中的dms伺服器ip位址加入至m...
如何使用訊息佇列的事務訊息
發訊息 過程，往往是為通知另外乙個系統更新資料，mq的 事務 主要解決訊息生產者和訊息消費者的資料一致性問題。先把商品加到購物車 然後幾件商品一起下單 最後支付 完成購物流程，就可以愉快地等待收貨 該過程中有個需用mq。訂單系統建立訂單後，發訊息給購物車模組，將已下單商品從購物車刪除。從購物車刪除已...