kafka window环境下使用（内置zookeeper）

下载

1. kafka 官网下载最新版本（已集成 zookeeper）
2. 解压到 D 盘的 kafka_2.12-2.3.0

运行 zookeeper

3. 执行 zookeeper 运行命令

   D:kafka_2.12-2.3.0inwindowszookeeper-server-start.bat D:kafka_2.12-2.3.0configzookeeper.properties
   

4. 执行结果
   

5. 默认端口号是 2181

运行 kafka

1. 打开新的命令行，执行：

   D:kafka_2.12-2.3.0inwindowskafka-server-start.bat D:kafka_2.12-2.3.0configserver.properties
   

2. 执行结果：

创建主题

1. 创建一个名为 topic_test 的主题，包含一个分区，只有一个副本

   D:kafka_2.12-2.3.0inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test
   

生产消息

D:kafka_2.12-2.3.0inwindowskafka-console-producer.bat --broker-list localhost:9092 --topic topic_test

消费消息

D:kafka_2.12-2.3.0inwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic_test --from-beginning