标签：opt 截图 单机版 -- zookeeper kafka 1.0 Kafka 2.11
衔接上文，若对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
标签：opt,截图,单机版,--,zookeeper,kafka,1.0,Kafka,2.11 来源： https://blog.csdn.net/m0_55710969/article/details/121459349
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。