需要掌握：kafka教程-从头消费数据：查看偏移量、删除偏移量

注意

需要 先停掉 flink 程序，然后再按照 kafka教程-从头消费数据：查看偏移量、删除偏移量 删除

如果不停掉 flink 程序，删除偏移量无效

操作

1. 断开 所有 消费 该主题 的消费者（否则删除无效）

2. 查看某 group组 的消费偏移量

   kafka-consumer-groups.sh --bootstrap-server hadoop1:9092 --group group_fl_dim --describe
   

3. 删除消费偏移量

   kafka-consumer-groups.sh --bootstrap-server hadoop1:9092 --group group_fl_dim --delete-offsets --topic fl-db
   

原文出处：/show_1GW1fEc3XVCi.html