1. 安装ZOOKEEPER
Kafka的运行依赖于Zookeeper,所以在运行Kafka之前我们需要安装并运行Zookeeper
1 下载安装文件: http://zookeeper.apache.org/releases.html,解压到E盘
2 打开E:\apache-zookeeper-3.6.2-bin\conf,把zoo_sample.cfg重命名成zoo.cfg
3 添加如下系统变量:
- ZOOKEEPER_HOME: E:\apache-zookeeper-3.6.2-bin (zookeeper目录)
- path: 在现有的值后面添加 “;%ZOOKEEPER_HOME%\bin;”
4 运行Zookeeper: 打开cmd,执行 zkserver
cmd 窗口不要关闭
2. 安装并运行KAFKA
2.1 下载安装文件: http://kafka.apache.org/downloads.html,解压到E盘
2.3 打开E:\kafka_2.13-2.7.0\config
2.4 进入kafka文件目录: cd E:\kafka_2.13-2.7.0(kafka目录)
2.5 执行: .\bin\windows\kafka-server-start.bat .\config\server.properties
cmd 窗口不要关闭
3. 创建TOPICS
3.1 打开cmd 并进入cd E:\kafka_2.13-2.7.0\bin\windows
3.2 创建一个topic: kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
4. 打开一个PRODUCER:
cd E:\kafka_2.13-2.7.0\bin\windows
kafka-console-producer.bat --broker-list localhost:9092 --topic test
5. 打开一个CONSUMER:
cd E:\kafka_2.13-2.7.0\bin\windows
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning