window的wsl（Ubuntu）安装kafka步骤

环境：Win11 + WSL(Linux子系统Ubuntu) +  apache-zookeeper-3.9.3-bin + kafka_2.12-3.8.1 

思路：apache上分别下载zookeeper和kafka，在wsl环境安装。在kafka上创建消息的topic，发送消息，接受消息，验证是否安装成功。

前提：先在ubuntu上安装JDK(sudo apt-get install default-jdk) ，参考WSL 安装及其中 Java 环境配置_wsl java -version不识别-CSDN博客

1、官网Apache ZooKeeper下载zookeeper

2、在PowerShell中用tar -zxf解压tar包

3、解压之后，将安装文件mv 到 /usr/local/zookeeper目录下（用mv命令可以修改目录名称）

4、修改zoo.cfg配置文件

cat > /usr/local/zookeeper/conf/zoo.cfg << EOF

>tickTime=2000

>dataDir=/var/lib/zookeeper

>clientPort=2180

>EOF

修改之后用cat命令查看修改结果：

5、启动zk(前提 ：先安装jdk)

6、下载安装kafka（步骤同zk）

7、启动zk

 bin/kafka-server-start.sh -daemon config/server.properties

8、创建topic

bin/kafka-topics.sh  --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

注意：用如下命令创建topic会出现错误“zookeeper is not a recognized option”

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

9、往topic上发布消息

 ./kafka-console-producer.sh --broker-list localhost:9092 --topic test

test message 1

test message 2

用ctr + d结束

9、从topic上接受消息（见上图）

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning