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