cd /opt  
wget http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz  
tar zxvf kafka_2.11-2.3.0.tgz  
mv kafka_2.11-2.3.0 /usr/local/apps/  
cd /usr/local/apps/  
ln -s kafka_2.11-2.3.0 kafka

cd /usr/local/apps/kafka  
#执行脚本  
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties  
#查看进程  
jps

#执行脚本  
bin/kafka-server-start.sh config/server.properties  
#查看进程  
jps

#执行脚本  
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

#执行脚本  
bin/kafka-topics.sh --list --zookeeper localhost:2181  
输出：test

#执行脚本(使用kafka-console-producer.sh 发送消息)  
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

#执行脚本(使用kafka-console-consumer.sh 接收消息并在终端打印)  
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test