我有 kafka 中給定主題的分區號和偏移量之間的映射。我想使用 golang 消耗從頭開始到特定分區/偏移映射的所有消息。簡而言之，我想知道是否可以從頭到特定偏移量消費kafka中的消息。我想知道在開始實施某些事情之前是否有內置工具或庫可以幫助我做一些事情。
1 回答
慕標5832272
TA貢獻1966條經驗 獲得超4個贊
因為我 99.9% 相信這是正確的 - 您無法指定 Consumer 上的結束偏移量。Consumer API 支持 OOTB：
從頭開始。
從任意位置開始。
從最后開始。
請注意，沒有指定范圍的選項，但您可以輕松地自己執行此操作：只需從頭開始，并在讀取所需數量的消息（例如最終偏移量）后停止。
- 1 回答
- 0 關注
- 122 瀏覽
添加回答
舉報
0/150
提交
取消