Docker Kafka手动重置 offset

sudo docker ps #查询所有正在运行的容器信息

sudo docker exec -it yourContainerId /bin/sh #进入kafka容器

cd /opt/bitnami/kafka/bin #进入kafka工作目录

./kafka-topics.sh --zookeeper zookeeper:2181 --list #查看topic

#获取topic详情

./kafka-topics.sh --zookeeper zookeeper:2181 --describe --topic ether_topic_block

#设置消费组到任意的offset

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group yourGroupID --topic yourTopicName --reset-offsets --to-offset 2061170 --execute

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group dwdGroup007 --topic yourTopicName --reset-offsets --to-offset 348196000 --execute

#查询kafka最大的offset

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic yourTopicName --time -1

#查询kafka最小的offset:

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic yourTopicName --time -2