使用kafka-consumer-group.sh重新设置offset报错

怀疑某一天发送到kafka的数据不全, 需要重新消费2018-12-28号的数据,但是使用kafka-consumer-group.sh可以重置offset到earliest 或者latest ,但是使用 --to-datetime就会报错。附上报错信息

代码如下

./kafka-consumer-groups.sh --bootstrap-server server:port --reset-offset --to-datetime 
2018-12-28T00:00:00.000 --topic topic --group group

报错信息为:

executing consumer group command failed due to null





发表于: 2月前   最后更新时间: 2月前   游览量:216
上一条: 到头了!
下一条: 已经是最后了!