菜单 学习猿地 - LMONKEY

VIP

开通学习猿地VIP

尊享10项VIP特权 持续新增

知识通关挑战

打卡带练!告别无效练习

接私单赚外块

VIP优先接,累计金额超百万

学习猿地私房课免费学

大厂实战课仅对VIP开放

你的一对一导师

每月可免费咨询大牛30次

领取更多软件工程师实用特权

入驻
234
0

kafka window安装与配置

原创
05/13 14:22
阅读数 16836

一、安装jdk1.8
(此处省略)

二、安装zookeeper
1. 下载安装包:http://zookeeper.apache.org/releases.html,解压到指定目录(如下)

2. 在系统变量中添加ZOOKEEPER_HOME = C:\Users\wcy\Downloads\Compressed\zookeeper-3.4.10

3. 编辑path系统变量,添加为路径%ZOOKEEPER_HOME%\bin;

4. 将conf下“zoo_sample.cfg”重命名为“zoo.cfg”

5. 在任意文本编辑器(如notepad)中打开zoo.cfg. 找到并编辑dataDir=C:/dataDir

6. 找到并编辑dataDir=C:/dataDir

7. 打开新的cmd,输入zkServer,运行Zookeeper。

8. 命令行提示如下:说明本地Zookeeper启动成功

 

 

 

三、安装kafka
1.下载 http://mirrors.shu.edu.cn/apache/kafka/1.0.0/kafka_2.11-1.0.0.tgz ,解压为kafka_2.11-1.0.0,

2.进入Kafka配置目录,C:\Users\wcy\Downloads\kafka_2.11-1.0.0\config ,编辑文件“server.properties” 添加自己的日记目录:log.dirs=...   同时打开注释 listeners=PLAINTEXT://:9092。如果Zookeeper在某些其他的机器或集群上运行,可以将“zookeeper.connect:2181”修改为自定义IP与端口。在这里使用了同一个机器,所以没其他做修改。文件中的Kafka端口和broker.id也是可以配置的。默认设置不变。

3.在zookeeper的基础上,运行Kafka服务 
进入Kafka安装目录,C:\Users\wcy\Downloads\kafka_2.11-1.0.0
切换到命令行窗口,运行kafka。 

.\bin\windows\kafka-server-start.bat .\config\server.properties

 

运行成功,会有log文件的输出,连接zk的2181端口,启动默认的9092端口

 

 

四、测试
A、创建主题 
1. 现在创建主题,命名为“test”,replication factor=1(因为只有1个Kafka服务器在运行)。如果集群中所运行的Kafka服务器不止1个,可以相应增加replication-factor,从而提高数据可用性和系统容错性。

2. 在C:\Users\wcy\Downloads\kafka_2.11-1.0.0\bin\windows打开新的命令行。 

3. 输入下面的命令,回车:kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test 

B. 创建Producer及Consumer来测试服务器。 

1.在C:\Users\wcy\Downloads\kafka_2.11-1.0.0\bin\windows打开新的命令行。 

2.输入以下命令,启动producer,可以输入消息:kafka-console-producer.bat –broker-list localhost:9092 –topic test 

3.在同样的位置C:\Users\wcy\Downloads\kafka_2.11-1.0.0\bin\windows再次打开新的命令行。 

4.现在输入下列命令启动consumer,可以获取消息:kafka-console-consumer.bat –zookeeper localhost:2181 –topic test 

5.两个命令行窗口,producer可以输入任何消息,consumer可以获取消息。

 

 

 

 

 


————————————————
版权声明:本文为CSDN博主「mazda车神」的原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/weixin_40255824/article/details/80167719

发表评论

0/200
234 点赞
0 评论
收藏