Windows系统下使用Kafka和Zookeeper，Python运行kafka（一）

下载和安装见Linux系统下使用Kafka和Zookeeper

配置 Zookeeper

Zookeeper 是 Kafka 所依赖的分布式协调服务。在 Kafka 解压目录下，有一个 Zookeeper 的配置文件模板config/zookeeper.properties，你可以直接使用默认配置。

启动 Zookeeper

打开命令提示符（CMD），进入 Kafka 解压目录

我的是放在该目录下：cd F:\kafka_2.13-3.8.0
执行以下命令启动 Zookeeper

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

要是 Zookeeper 成功启动，命令提示符窗口会显示相关日志信息。

如果启动失败可以检查一下Zookeeper 默认使用的 2181 端口
Kafka 默认使用 9092 端口

查看进程：netstat -ano | findstr :2181
杀死进程：taskkill /F /PID 6084

配置 Kafka

Kafka 的配置文件是config/server.properties，你可以使用默认配置。不过，要确保zookeeper.connect参数指向 Zookeeper 的地址和端口，默认是localhost:2181

启动 Kafka

在另一个命令提示符窗口中，进入 Kafka 解压目录，执行以下命令启动 Kafka

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

要是 Kafka 成功启动，命令提示符窗口会显示相关日志信息。

在kafka里面的config/server.properties文件中，有日志文件的目录

如果kafka启动失败可以把这文件夹删了，它又会自动生成的

创建 Kafka 主题

Kafka 主题是消息的分类，你可以使用以下命令创建一个名为test的主题：

.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

python代码创建主题

<