kafka API 读某个消费者的offset不成功

it2025-02-16  4

要自己管理kafka的offset,所以要读取earlist,latest和current的offset今天整了一下午,读不出来某个消费者的offset。

原来是 auto.offset.reset 设置不能为none.

设置为none时topic各分区都存在已提交的offset时,从offset后开始消费;只要有一个分区不存在已提交的offset,则抛出异常

最新回复(0)