【发布时间】:2020-07-07 19:24:13
【问题描述】:
我想删除 __consumer_offsets 表中包含的所有以给定键开头的消息(重置一个特定的消费者组而不影响其余的消费者组)。
有没有办法做到这一点?
【问题讨论】:
标签: apache-kafka
我想删除 __consumer_offsets 表中包含的所有以给定键开头的消息(重置一个特定的消费者组而不影响其余的消费者组)。
有没有办法做到这一点?
【问题讨论】:
标签: apache-kafka
Kafka 带有一个 ConsumerGroupCommand 工具。您可以在 Kafka documentation 中找到一些信息。
如果您打算重置特定的消费者组(“myConsumerGroup”)而不影响您可以使用的其余部分
> bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --group myConsumerGroup --topic topic1 --to-latest
根据您的要求,您可以使用该工具重置主题的每个分区的偏移量。帮助功能或文档解释了这些选项。
【讨论】: