kafka的安装及运行

kafka的安装及运行,第1张

kafka的安装及运行

kafka的安装运行需要共三条件:

1、JDK安装环境

2、安装ZooKeeper

3、安装Kafka

一、JDK安装环境

略。。。。。。。。。

二、安装ZooKeeper

1、下载安装包:

链接:https://pan.baidu.com/s/1Owh_rOEg48X1cDJV-jU6AQ 
提取码:az9c

2、解压安装包并进入安装目录,D:zookeeperapache-zookeeper-3.6.3-bin

3、复制"zoo_sample.cfg"文件并重命名为"zoo.cfg"

4、用记事本打开"zoo.cfg"文件,找到"dataDir"变量,修改为本地安装路径(dataDir=D:zookeeperapache-zookeeper-3.6.3-bin)

5、配置系统环境变量,新增环境变量(ZOOKEEPER_HOME = D:zookeeperapache-zookeeper-3.6.3-bin)

6、编辑path系统变量,添加路径(%ZOOKEEPER_HOME%bin)

7、打开命令窗口(cmd),输入"zkServer",运行ZooKeeper

即成功,不要关闭该窗口

三、安装Kafka 

 1、下载安装包:

链接:https://pan.baidu.com/s/10ifvEitQUoiKr762ZMnkdQ 
提取码:nkpq

2、解压安装包并进入安装目录,D:kafkakafka_2.11-2.4.0

3、进入config目录,找到并打开server.propertes文件

4、找到"log.dirs"变量,修改为本地安装路径并拼接kafka-logs(log.dirs=D:kafkakafka_2.11-2.4.0kafka-logs)

5、找到"zookeeper.connect"变量,修改变量值(zookeeper.connect=localhost:2181)

6、kafka默认端口:9092;ZooKeeper默认端口2181

7、进入Kafka安装目录(D:kafkakafka_2.11-2.4.0),打开命令窗口,输入命令(第二条笔者测试无效)

.binwindowskafka-server-start.bat .configserver.properties
或binkafka-server-start.sh configserver.properties

-------- 效果展示 

 即成功,不要关闭该窗口。

四、测试

1、创建主题:打开新的命令窗口,输入命令(aaa即为主题名称):

.binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic aaa

-------- 效果展示 

2、查看主题:输入命令:

 .binwindowskafka-topics.bat --list --zookeeper localhost:2181

 -------- 效果展示 

3、创建生产者:输入命令(bbb即为生产者名称):

.binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic abc

  -------- 效果展示 (此为生产者窗口,需手动输入)

 即成功,不要关闭该窗口。

 4、创建消费者:进入Kafka安装目录,打开新的命令窗口,输入命令

 .binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic abc  --from-beginning

 -------- 效果展示(在生产者窗口进行手动输入,消费者窗口显示数据)

 即成功。

5、查看topic,打开命令窗口,进入kafka安装目录,输入命令

.binwindowskafka-topics.bat --describe --zookeeper localhost:2181 --topic

 -------- 效果展示(笔者效果不佳,还未找到原因,欢迎大家投稿)

 参考地址:https://www.cnblogs.com/cwb123/p/13832836.html

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5706221.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-17
下一篇 2022-12-17

发表评论

登录后才能评论

评论列表(0条)

保存