启动zookeeper
在 /usr/local/kafka目录下执行：
bin/zookeeper-server-start.sh config/zookeeper.properties
启动kafka
打开另一个终端（之前的终端不要关闭，否则zookeeper会停止）
bin/kafka-server-start.sh config/server.properties
测试命令
再打开一个终端
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
这里出现error是因为我之前已经创建了test这个topic。正常情况下会显示Created topic test。
利用list命令列出所有创建了的topics,来产看刚才创建的topic是否存在，命令如下：
./bin/kafka-topics.sh --list --zookeeper localhost:2181
创建 producer(生产者): 测试生产消息
bin/kafka-console-producer.sh --broker-list localhost:9092 -topic test
>hello world
>hello1111
创建 consumer(消费者): 测试消费
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 -topic test --from-beginning
上面这个是比较新的版本的命令，老版本的命令：
bin/kafka-console-consumer.sh --zookeeper localhost:2181 -topic test --from-beginning
删除 topic:
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test