1.建立一个测试主题:
[root@snn bin]#./kafka-topics.sh --zookeeper snn:2181 --topic offset-test --partitions 2 --replication-factor 2 –create
检查主题的设置情况:
[root@snn bin]#./kafka-topics.sh --zookeeper snn:2181 --topic offset-test –describe
2.向主题中写入数据
[root@snn bin]# ./kafka-console-producer.sh --broker-list snn:6667 --topic offset-test
3.消费主题
[root@snn bin]# ./kafka-console-consumer.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test –from-beginning
4.查看消费者消费偏移量
[root@snn bin]#./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest –describe
5.设置为最初偏移量:
[root@snn bin]#./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-earliest –execute
重新读取数据:
6.设置任意偏移量:
[root@snn bin]# ./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-offset 3 –execute
7.设置最近偏移量
[root@snn bin]# ./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-latest --execute
参考文章:https://www.cnblogs.com/felixzh/p/8028118.html