对kafka整个集群设置偏移量大家使用较多，适合测试环境，丢弃整个消息队列中的数据：
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group_mytest --reset-offsets --all-topics --to-latest --execute二、指定topic的指定分区设置偏移量
当一个topic存在多个分区，其中单个分区产生堆积时，生产环境中显然不适合丢弃整个topic的数据，所以，为了尽量减少对生产数据的影响，可以对指定的分区重设偏移量
1、首先查看当前分区情况以及消费组信息：
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my_group
CURRENT-OFFSET：将这个值调大，则可以丢弃掉指定分区的一部分数据
2、然后根据具体积压的分区情况，设置指定分区的偏移量：
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group my_group --reset-offsets --topic my_topic:10 --to-offset 123123123 --execute
–topic kafkatest:10：10表示分区
–to-offset 123123123
3、如果出现报错：
Error: Assignments can only be reset if the group ‘my_group’ is
inactive, but the current state is PreparingRebalance.
说明指定的消费组处于活跃状态，需要停止消费之后，才能操作。
