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

不过一念间 发表于: 2018-12-29   最后更新时间: 2018-12-29 19:56:37   2,575 游览

怀疑某一天发送到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
添加评论
你的答案

查看kafka相关的其他问题或提一个您自己的问题