1. 安装JDK
1.1 安装文件:http://www.oracle.com/technetwork/java/javase/downloads/index.html 下载JDK
1.2 安装完成后需要添加以下的环境变量(右键点击“我的电脑” -> "高级系统设置" -> "环境变量"):
- JAVA_HOME: D:JobToolJavajdk1.8.0_171 (jdk的安装路径)
- Path: 在现有的值后面添加"; %JAVA_HOME%in"
1.3 打开cmd运行 "java -version" 查看当前系统Java的版本:
2. 安装ZOOKEEPER
Kafka的运行依赖于Zookeeper,所以在运行Kafka之前我们需要安装并运行Zookeeper
- ZOOKEEPER_HOME: C:UserslocaladminCODEzookeeper-3.4.13 (zookeeper目录)
- Path: 在现有的值后面添加 ";%ZOOKEEPER_HOME%in;"
2.7 运行Zookeeper: 打开cmd然后执行 zkserver
cmd 窗口不要关闭
3. 安装并运行KAFKA
cmd 窗口不要关闭
4. 创建TOPICS
cmd 窗口不要关闭
5. 打开一个PRODUCER:(生产者)
cd D:软件kafka_2.12-2.6.0inwindows(kafka目录下binwindows)
kafka-console-producer.bat --broker-list localhost:9092 --topic test
cmd 窗口不要关闭
6. 打开一个CONSUMER: (消费者)
cd D:软件kafka_2.12-2.6.0inwindows(kafka目录下binwindows)
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
cmd 窗口不要关闭
7. 测试:
参考地址:https://www.cnblogs.com/lnice/p/9668750.html