Kafka64 条

删除消费组

删除消费组会清除其位移记录:下次同组名启动时按 auto.offset.reset 从最早或最新开始,这也是常用的“重新消费”手段。

命令--delete --group <组名>
后果位移记录删除;组内成员必须为空
替代只想跳数据用位移重置,不必删组

删除消费组

删除消费组
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
  --delete --group order-consumer
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list | grep order-consumer
删除组不影响主题数据,但依赖旧位移的下游会从零或从最新重读,操作前确认重放量。

易错点

  • 删除后同名组重启会读取 auto.offset.reset(默认 latest),容易得到“没有数据”的假象
  • 有活跃成员时删除会报错,先停消费者再执行

数据来源与参考

  • Apache Kafka 官方文档:Delete Consumer Groups
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌