衔接上文，若对kafka还不太了解的朋友请参考：
|?1.校验java环境及JDK是否已安装
java -version
若还没有安装，请先安装配置java环境：
Linux系统中Java环境的搭建及JDK的安装（附上每一步操作截图及说明）【一看就懂】_杨大仙-CSDN博客
| 2.上传kafka文件至虚拟机中
官网下载链接：Apache Kafka
本文使用该版本为例（kafka_2.11-1.0.0.tgz）
准备好压缩包后将其上传至虚拟机：如图所示：
解压刚上传的kafka压缩文件：
tar -zxvf kafka_2.11-1.0.0.tgz
| 3.切换到kafka的配置文件目录
kafka安装目录下的config文件夹为其存放配置文件的位置
从根目录进入命令：（快捷生成文件名方式，敲一个文件首字母后按Tab键即可自动生成）
cd /opt/kafka_2.11-1.0.0/config/
| 4.修改server.properties和zookeeper.properties配置文件
使用vim编辑器打开server.properties配置文件界面如下所示，并使用命令调出行号
若对vim编辑器不太了解的请参考：
vim server.properties
:set nu --->显示行号
将第31行左右listeners复制并添加本机ip；?
修改日志路径，分区数，可根据需求修改。
修改完成后保存退出配置文件。并创建对应配置文件中日志存放位置的文件夹：
再使用vim编辑器进入zookeeper.properties
文件内容非常的少，我们只需参考图示进行操作即可:?
需要开放防火墙中 2181 端口和 9092 端口。
对防火墙规则不太了解的朋友请参考：(本文就不做开放防火墙演示了，避免文章过于冗余)
操作完成后保存并退出该配置文件。
| 5.启动
到此呢Kafka单机版安装就已经成功，接下来我们启动测试一下。
启动zookeeper
/opt/kafka_2.11-1.0.0/bin/zookeeper-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/zookeeper.properties
- 启动 kafka 之前需要启动 zookeeper 因为 kafka 依赖于 zookeeper ;
- 启动 zookeeper 要去加载 zookeeper 的配置文件 和启动 redis 时,加载 redis.conf 文件一样;
再启动kafka-server
如图所示：(这里使用了绝对路径，若你的kafka文件目录与我一致，复制即可)
/opt/kafka_2.11-1.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/server.properties
启动成功后使用jps查看进程，启动成功
jps若错误操作先启动了kafka，会出现如下错误：
kafka创建主题时循环报错 java.net.ConnectException: 拒绝连接...【已解决】_杨大仙-CSDN博客
| 5.1查看所有主题
复制后记得修改ip地址为你的ip地址；
/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --list --zookeeper 192.168.21.132:2181
目前还没有主题。
| 5.2创建主题
/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --create --zookeeper 192.168.21.132:2181 -partitions 1 --replication-factor 1 --topic test- replication-factor 1:?备份(副本) 最多为集群机器的台数 只能少不能多 单机版只能是1
- partitions 1: 分区数??
| 5.3删除主题
删除主题命令如下：就不做展示啦，嘿嘿
/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --delete --zookeeper 192.168.21.131:2181 --topic test| 5.4启动生产者（发送消息）
命令如下：(这里使用了绝对路径，若你的kafka文件目录与我一致，复制即可)
/opt/kafka_2.11-1.0.0/bin/kafka-console-producer.sh --broker-list 192.168.21.131:9092 --topic test
启动成功后可发送消息（如上图）；然后复制当前标签并打开，准备测试消费者；
| 5.5启动消费者（拉取消息）
命令如下：(这里使用了绝对路径，若你的kafka文件目录与我一致，复制即可)
/opt/kafka_2.11-1.0.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.21.131:9092 --topic test --from-beginning
参数：--from-beginning? ? ? ? ? 加上即代表从第一条开始接收
ok，到此我们便大功告成啦，祝玩的开心~
转载请注明出处
如有错误，欢迎指正
Thanks