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