前提
zookeeper安装参考：https://www.cnblogs.com/JustinLau/p/11372782.html
其他安装参考：https://www.cnblogs.com/luotianshuai/p/5206662.html
安装Kafka前需要先安装zookeeper集群，集体安装方法请参照我的另一篇文档。
Kafka安装
下载
wget https://archive.apache.org/dist/kafka/0.8.0/kafka_2.8.0-0.8.0.tar.gz
解压
tar -zxvf kafka_2.8.0-0.8.0.tar.gz
移动文件夹
mv kafka_2.8.0-0.8.0 /usr/local/hadoop/
修改配置
cd /usr/local/hadoop/config
vi server.properties
参照下图信息修改
Kafaka操作
启动kafka server
cd ../
bin/kafka-server-start.sh config/server.properties
创建主题
cd /usr/local/hadoop/bin
./kafka-create-topic.sh --partition 1 --replica 1 --zookeeper 192.168.6.100:2181,192.168.6.103:2181 --topic test
检查主题是否创建成功
./kafka-list-topic.sh --zookeeper 192.168.6.100:2181,192.168.6.103:2181
启动producer
./kafka-console-producer.sh --broker-list 192.168.6.100:9092 --topic test
输入hello后，回车 ，然后另外打开一个shell终端
启动consumer
./kafka-console-consumer.sh --zookeeper 192.168.6.100:2181,192.168.6.103:2181 --topic test
关闭kafka
./kafkastop.sh
新版本命令
---new version--
./kafka-topics.sh --create --zookeeper 192.168.6.100:2181,192.168.6.103:2181 --replication-factor 1 --partitions 1 --topic test
./kafka-topics.sh --list --zookeeper 192.168.6.100:2181,192.168.6.103:2181
./kafka-console-producer.sh --broker-list 192.168.6.100:9092 --topic test
./kafka-console-consumer.sh --zookeeper 192.168.6.100:2181,192.168.6.103:2181 --topic test --from-beginning
附：有可能遇到的问题和解决方案
问题1： Failed to acquire lock on file .
这里写图片描述
解决方案：
这是因为之前已经有kafka进程在运行，可以如下：
通过jps命令查看进程号，并kill掉，然后重新启动kafka即问题解决
