我有一個 akka 應用程序（在 JAVA 中），用于commitablePartitionedSource使用來自 kafka 主題的消息。我有幾個消費者群體，可以為多個主題吸引消費者。這是由動態配置驅動的，我可以在其中暫時關閉消費者，并可能在稍后重新啟動它們。當這個消費者重新啟動時，我只想閱讀新消息，而不是從我離開的地方開始。有沒有辦法從 akka-alpakka 消費者那里獲取 kafkaConsumer 對象，以便我可以在處理之前使用 seekToEnd()？請讓我知道是否還有其他方法可以實現這一目標？也許使用 akka 配置或不同類型的消費者？我不想維護自己的偏移量（希望不是唯一的選擇）我的配置設置為latest在我啟動消費者組時獲取偏移量，但由于我正在關閉并重新啟動單個消費者，它總是從我停止的地方開始消費。我嘗試為一個主題創建一個消費者組，但我有很多主題，而且結果非常耗費資源。我還尋找一種方法來清除存儲在 kafka 中的該主題的偏移量，但沒有成功。