【发布时间】:2018-10-08 06:12:09
【问题描述】:
将kafka消费者偏移量重置为最早时,它会保留一些偏移量> 0的分区
$ kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group group1 --topic topic1 --reset-offsets --to-earliest --execute
演出:
TOPIC PARTITION NEW-OFFSET
topic1 4 0
topic1 1 6153734
topic1 3 0
topic1 2 0
topic1 0 0
为什么分区 1 也没有 0?
【问题讨论】:
标签: apache-kafka