返回到文章

采纳

编辑于

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

kafka

怀疑某一天发送到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