这里是安装kafka_2.10-0.10.1.0.tgz版本，可以到官网下载。
官网地址：https://kafka.apache.org/downloads

cd ~/下载
sudo tar -zxf kafka_2.10-0.10.1.0.tgz -C /usr/local
cd /usr/local
sudo mv kafka_2.10-0.10.1.0/ ./kafka
sudo chown -R hadoop ./kafka

测试简单实例

接下来在Ubuntu系统环境下测试简单的实例。

# 进入kafka所在的目录
cd /usr/local/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

命令执行后不会返回Shell命令输入状态,zookeeper就会按照默认的配置文件启动服务,请千万不要关闭当前终端.启动新的终端，输入如下命令：

cd /usr/local/kafka
bin/kafka-server-start.sh config/server.properties

kafka服务端就启动了,请千万不要关闭当前终端。启动另外一个终端,输入如下命令:

cd /usr/local/kafka
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wordsendertest

topic是发布消息发布的category,以单节点的配置创建了一个叫wordsendertest的topic.可以用list列出所有创建的topics,来查看刚才创建的主题是否存在。

bin/kafka-topics.sh --list --zookeeper localhost:2181  

可以在结果中查看到dblab这个topic存在。接下来用producer生产点数据：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic wordsendertest

并尝试输入如下信息：

hello spark
hello kafka
hadoop world

然后再次开启新的终端或者直接按CTRL+C退出。然后使用consumer来接收数据,输入如下命令：

cd /usr/local/kafka
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic wordsendertest --from-beginning  

便可以看到刚才产生的三条信息。说明kafka安装成功。

---------------------------------------------------------------------提示---------------------------------------------------------------------
如果你在部署过程中，遇到什么问题，可以通过评论区加我微信，我们相互讨论。共同成长！！！

---------------------------------------------------------------------提示---------------------------------------------------------------------