Window 下载安装 Kafka

安装准备

• 安装 JDK
• https://blog.csdn.net/qq_35246620/article/details/61208961
• 安装 Zookeeper
• https://blog.csdn.net/Future_LL/article/details/83094672

安装 Kafka

• 下载安装包
  • http://kafka.apache.org/downloads
  • 
• 解压并进入 Kafka 目录
  • 
  • 我的路径：D:\Kafka\kafka_2.12-1.0.0
• 进入 config 目录找到文件 server.properties 并打开
  • 
• 找到并编辑 log.dirs=D:\Kafka\kafka_2.12-1.0.0\kafka-logs
  • 
• 找到并编辑 zookeeper.connect=localhost:2181
  • 
• Kafka 会按照默认，在 9092 端口上运行，并连接 Zookeeper 的默认端口：2181
  • Window 下 ZooKeeper 安装以及检测
  • https://blog.csdn.net/Future_LL/article/details/83094672
  • 注意启动后窗口不能关闭
  • 先要启动 Zookeeper，才能启动 Kafka
• 进入 Kafka 安装目录 D:\Kafka\kafka_2.12-1.0.0，在当前路径打开 cmd
  • 
  • 
• 输入如下代码：
  • .\bin\windows\kafka-server-start.bat .\config\server.properties
  • 、
  • 这个窗口不能关闭

测试

• 创建主题，进入Kafka安装目录 D:\Kafka\kafka_2.12-1.0.0，在该路径下打开 cmd，输入如下代码：
  • .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  • 
  • 窗口不关闭
• 查看主题，输入如下代码：
  • .\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
  • 
• 创建生产者，输入如下代码：
  • .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
  • 
• 创建消费者，输入如下代码：
  • .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
  • 
• 现在只要在生产者中输入消息，消费者都会接收相应消息