说明

同一个 group组，消费数据后，再次消费时，是从上一个位置继续消费，相当于迅雷的断点续传

如何从头读取数据

• 换一个新的group组，并设置从头读取数据（简单）

• 删除该group组的偏移量（需要敲命令）

删除该group组的偏移量

1. 先查看该group组的偏移量
2. 删除
3. 再次查看是否生效

查看某 group组 的消费偏移量

通过下面命令查看：

kafka-consumer-groups.sh --bootstrap-server 【kafka服务器】:9092 --group 【group组】 --describe

例子

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

执行结果：

可以看到：

• 当前偏移量是 84064
• 最后偏移量是 84064

删除该组在该主题的偏移量

kafka-consumer-groups.sh --bootstrap-server 【kafka服务器】:9092 --group 【group组】 --delete-offsets --topic 【主题】

例子

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

表示删除成功

再次查看

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

执行结果：

已经不存在了

原文出处：/show_1GW1fE1kC0sC.html