生产者
./kafka-console-producer.sh --broker-list 192.168.186.29:9092 --topic norm
消费者
./kafka-console-consumer.sh --zookeeper 192.168.186.29:2181 --from-beginning --topic norm
查询topic的offset
offset最小值
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.186.29:9092 -topic norm --time -2
offset最大值
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list slave6:9092 -topic videoplay --time -1
可以查询出offset的范围