【问题标题】:Kafka 1.0 reseting offset doesn't reset all partitions to 0Kafka 1.0 重置偏移量不会将所有分区重置为 0
【发布时间】: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


    【解决方案1】:

    问题是最早的偏移量确实是 6153734

    使用--reset-offsets --to-offset 0找到它

    输出

    WARN New offset (0) is lower than earliest offset. Value will be set to 6153734 (kafka.admin.ConsumerGroupCommand$)
    

    【讨论】:

    • 是否可以将其设置为 0 ?如果是这样,如何?
    • 可能通过删除主题因为第一个偏移量是6153734
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2019-07-20
    • 1970-01-01
    • 1970-01-01
    • 2019-11-28
    • 2018-01-22
    • 2018-01-30
    • 1970-01-01
    相关资源
    最近更新 更多