【Kafka】Kafka Windows安装及底子测试订阅发布

 由于这是自己刚安装测试踩坑的实践经验内容，就不引入关于zookeeper、kafa的理论知识了，更多理论以及测试有必要可以跳看完这篇Kafka，你也许就会了Kafka-CSDN博客
 废话不多说，直接上
1.安装Java环境

1.1 安装文件：Java Downloads | Oracle 下载JDK
1.2 安装完成后必要添加以下的环境变量（右键点击“我的电脑” -> “高级系统设置” -> “环境变量” ）：
• JAVA_HOME: D:\Java\jdk1.8.0_171 (jdk的安装路径)
• Path: 在现有的值背面添加”; %JAVA_HOME%\bin”
1.3 打开cmd运行 【java -version”】检察当前系统Java的版本：
2.安装ZOOKEEPER

Kafka的运行依靠于Zookeeper，所以在运行Kafka之前我们必要安装并运行Zookeeper
2.1 下载安装文件： Apache ZooKeeper
2.2 解压文件
2.3 打开zookeeper-3.8.4\conf，把zoo_sample.cfg重命名成zoo.cfg
2.4 从文本编辑器里打开zoo.cfg
2.5 把dataDir的值改成“./zookeeper-3.8.4/data”（zookeeper具体路径文件夹名）
2.6 添加如下系统变量：
• ZOOKEEPER_HOME: D:\Tools\zookeeper-3.8.4 (zookeeper目录)
• Path: 在现有的值背面添加 “;%ZOOKEEPER_HOME%\bin;”
2.7 运行Zookeeper: 打开cmd，进入其bin文件夹下，然后执行 【zkserver】
注：运行zkserver报错：“exiting jvm with code 4”的环境一样寻常是端口被占用，可以在配置文件里手动加   admin.serverPort=17777(端口随意)，更具体原因可跳转：ZooKeeper audit is enabled. Exiting JVM with code 4_error exiting jvm with code 4-CSDN博客

打印出这些内容就是正常了
2.8 cmd 窗口不要关闭，关闭即制止服务
3.安装并运行KAFKA

3.1 下载安装文件： Apache Kafka
3.2 解压文件
3.3 打开kafka_2.13-3.8.1\config
3.4 从文本编辑器里打开 server.properties
3.5 把 log.dirs的值改成 “./logs”
3.6 修取消注释并改 listeners 和 advertised.listeners 的host和ip
3.7 打开cmd
3.8 进入kafka文件目录: cd D:\Tools\kafka_2.13-3.8.1(实际kafka根目录)
3.9 输入并执行: 【.\bin\windows\kafka-server-start.bat .\config\server.properties】

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

复制代码

正常会打印含有以下内容

3.10 cmd 窗口不要关闭
4.创建TOPICS

4.1 打开cmd 并进入cd D:\Tools\kafka_2.13-3.8.1\bin\windows
4.2 创建一个topic：【kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test】

1. kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

复制代码

注意
        经过安装实测，如果安装的kafka版本比较高，那就会报错：
Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
这时必要--zookeeper localhost:2181更换为--bootstrap-server localhost:9092
前者是老版本用zookeeper创建的端口是2181，后者是新版本的创建方式，9092是kafka的启动端口
此处必要注意，所有配置的单例kafka的ip和地址必要完全对应，否则也会不成功
端口如果配置错了，会出现错误：Error while executing topic command : Timed out waiting for a node assignment. Call: createTopics
正确新版命令如下
【kafka-topics.bat --create --bootstrap-server 10.10.0.46:9092 --replication-factor 1 --partitions 1 --topic test】

1. kafka-topics.bat --create --bootstrap-server 10.10.0.46:9092 --replication-factor 1 --partitions 1 --topic test

复制代码

执行后正常会打印出Created topic test.

5.打开一个PRODUCER

1.打开新的cmd并进入cd D:\Tools\kafka_2.13-3.8.1\bin\windows
2.执行【kafka-console-producer.bat --broker-list 10.10.0.46:9092 --topic test】

1. kafka-console-producer.bat --broker-list 10.10.0.46:9092 --topic test

复制代码

6.打开一个CONSUMER

1.打开新的cmd并进入cd D:\Tools\kafka_2.13-3.8.1\bin\windows
2.执行【kafka-console-consumer.bat --bootstrap-server 10.10.0.46:9092 --topic test --from-beginning】

1. kafka-console-consumer.bat --bootstrap-server 10.10.0.46:9092 --topic test --from-beginning

复制代码

7.测试发布订阅相应

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。