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