1.建立一個測試主題：

[[email protected] bin]#./kafka-topics.sh --zookeeper snn:2181 --topic offset-test --partitions 2 --replication-factor 2 –create

檢查主題的設定情況：

[[email protected] bin]#./kafka-topics.sh --zookeeper snn:2181 --topic offset-test –describe

2.向主題中寫入資料

[[email protected] bin]# ./kafka-console-producer.sh --broker-list snn:6667 --topic offset-test

3.消費主題

[[email protected] bin]# ./kafka-console-consumer.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test –from-beginning

4.檢視消費者消費偏移量

[[email protected] bin]#./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest –describe

5.設定為最初偏移量：

[

重新讀取資料:

6.設定任意偏移量：

[[email protected] bin]# ./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-offset 3 –execute

7.設定最近偏移量

[[email protected] bin]# ./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-latest --execute