衔接上文，若对kafka还不太了解的朋友请参考：

一文带你了解Kafka【一看就懂】_杨大仙-CSDN博客

| 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编辑器不太了解的请参考：

Linux系统中 vi/vim编辑器 的介绍及使用大全 详解【一看就懂】_杨大仙-CSDN博客_vim键盘

vim server.properties

:set nu            --->显示行号

将第31行左右listeners复制并添加本机ip； 

修改日志路径，分区数，可根据需求修改。

修改完成后保存退出配置文件。并创建对应配置文件中日志存放位置的文件夹：

再使用vim编辑器进入zookeeper.properties

文件内容非常的少，我们只需参考图示进行操作即可: 

需要开放防火墙中 2181 端口和 9092 端口。

对防火墙规则不太了解的朋友请参考：(本文就不做开放防火墙演示了，避免文章过于冗余)

【黑客必备】Linux系统中防火墙Firewall操作详解（附上图示及说明）【一看就懂】_杨大仙-CSDN博客

操作完成后保存并退出该配置文件。

| 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