消息队列MQ

Kafka单机版安装教程及测试(附每一步操作截图及说明)【一看就懂】

本文主要是介绍Kafka单机版安装教程及测试(附每一步操作截图及说明)【一看就懂】,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

衔接上文,若对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

这篇关于Kafka单机版安装教程及测试(附每一步操作截图及说明)【一看就懂】的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!