7Kafka 安装 · SpringCloud微服务实战 · 看云

导航

本节只说明Windows版的安装（安装包我放置在交流群里面了），Linux 的安装，统一放在Linux 模块

1. 下载

  1. 打开官网 下载地址
    7089b78e0749940cb94e98782e105083_MD5.webp
  2. 我这里已经提供了kafka_2.11-2.4.0.tgz，已经传到群里面
    解压并进入到 kafka_2.11-2.4.0\bin\windows

2. 启动ZooKeeper

zookeeper-server-start.bat ..\..\config\zookeeper.properties

72de0a1e7129233afcb91c0699060157_MD5.webp

3. 启动Kafka

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

a7dd86307952ceaafb9d39a9ba61be0e_MD5.webp

4. 创建一个主题

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

551c5c52251b880837e1dac11b425466_MD5.webp

5. 查看创建的主题列表

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

46d854c174dadf5758758fc92ac10828_MD5.webp

6. 启动生产者

kafka-console-producer.bat --broker-list localhost:9092 --topic fwcloud

7. 启动消费者

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic fwcloud --from-beginning

9019572f347ec16c70ef4adc950123f3_MD5.png

8.验证

在服务端输入hello world、nihao 客户端就会把hello world、nihao输出出来
0315e6b8b34adcc55b30f72f41ac1d58_MD5.png

启动kafka保错：命令过长语法不正确
解决方法就是：把kafka的目录从桌面移到别处，因为目录层级太深或者是目录名字太长导致的。比如放到D盘根目录

9.zkui 安装

zookeeper节点的可视化操作界面，比较方便

9.1 下载源码包

地址：https://github.com/DeemOpen/zkui
cmd 到pom.xml 所在的文件夹

mvn clean install

2de6fd37c33a889042968a32a1db22f1_MD5.png

9.2 启动

将config.cfg copy到 target包内

java -jar zkui-2.0-SNAPSHOT-jar-with-dependencies.jar

1c2f6883e0fa7abf3107373ab9b1cd4d_MD5.png

9.3 浏览器验证

默认地址http://localhost:9090
默认账号密码:admin/manager
e2d72c390f4d35e74141dc870abd3614_MD5.png

9.4 配置修改

修改config.cfg，并和编译好的jar包放在一起
b3da108fff57e0b01ba287a024e69f8a_MD5.png