如果您使用的是0.10.x，并且没有在0.11中添加的很棒的偏移管理工具，那么就有一个使用kafka-console-consumer.sh来更改消费组偏移的黑客程序。不过，这只适用于数字偏移量，而不适用于时间戳。
首先，停止正在运行的使用该使用者的任何进程。完全关闭是最好的。然后，运行如下命令：

bin/kafka-console-consumer.sh --bootstrap-server :9092 \
    --topic my-topic \
    --partition 1 \
    --consumer-property group.id=my-consumer-group \
    --max-messages 0 \
    --offset 12345
``` `--max-messages 0` 在这里很重要；将其设置为任何其他值（包括1）将消耗那么多消息，然后提交该主题/分区中的当前最新偏移量。这一定是控制台使用者中的错误。
接下来，使用kafka-consumer-groups.sh检查您的工作：

./kafka-consumer-groups.sh --bootstrap-server :9092
--group my-consumer-group
--describe