要自己管理kafka的offset,所以要读取earlist,latest和current的offset今天整了一下午,读不出来某个消费者的offset。
原来是 auto.offset.reset 设置不能为none.
设置为none时topic各分区都存在已提交的offset时,从offset后开始消费;只要有一个分区不存在已提交的offset,则抛出异常