Kafka 命令行工具位于 /usr/bin
- kafka-topics
创建，修改，显示和描述主题。例如：
$ /usr/bin/kafka-topics --zookeeper zk01.example.com:2181 --list sink1 t1 t2 $ /usr/bin/kafka-topics --zookeeper zk01.example.com:2181 --create --topic
- kafka-console-consumer
从Kafka主题读取数据并且输出到中断。例如：
$ /usr/bin/kafka-console-consumer --zookeeper zk01.example.com:2181 --topic t1
- kafka-console-producer
从终端读取数据并写入Kafka主题。 例如：
$ /usr/bin/kafka-console-producer --broker-list kafka02.example.com:9092,kafka03.example.com:9092 --topic t1
- kafka-consumer-offset-checker
注意：kafka-consumer-offset-checker 并不支持新的Consumer API
检查读取和写入的消息数量，以及指定consumer组中每个consumer的偏移量 例如：
$ /usr/bin/kafka-consumer-offset-checker --group flume --topic t1 --zookeeper zk01.example.com:2181