【问题标题】:delete specific messages from kafka topic __consumer_offsets从 kafka 主题 __consumer_offsets 中删除特定消息
【发布时间】:2020-07-07 19:24:13
【问题描述】:

我想删除 __consumer_offsets 表中包含的所有以给定键开头的消息(重置一个特定的消费者组而不影响其余的消费者组)。

有没有办法做到这一点?

【问题讨论】:

    标签: apache-kafka


    【解决方案1】:

    Kafka 带有一个 ConsumerGroupCommand 工具。您可以在 Kafka documentation 中找到一些信息。

    如果您打算重置特定的消费者组(“myConsumerGroup”)而不影响您可以使用的其余部分

    > bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --group myConsumerGroup --topic topic1 --to-latest
    

    根据您的要求,您可以使用该工具重置主题的每个分区的偏移量。帮助功能或文档解释了这些选项。

    【讨论】:

      猜你喜欢
      • 2019-07-07
      • 1970-01-01
      • 1970-01-01
      • 2018-05-19
      • 2020-02-16
      • 1970-01-01
      • 2020-12-21
      • 1970-01-01
      • 2016-12-18
      相关资源
      最近更新 更多