在windows安装并启动测试kafka

在windows安装并启动测试kafka

https://www.jianshu.com/p/ce203d4e2f41 从这个文章中学习

安装

http://kafka.apache.org/downloads 直接下载。根据所用的系统。

windows的直接在本地解压缩即可。

准备工作：

1、java环境

2、kafka安装包，（已包含zookeeper）

启动测试

我本地的windows的kafka的安装目录在 D:kafka_2.12-2.8.0

第一步： 新开窗口，启动zookeeper
D:kafka_2.12-2.8.0inwindows>zookeeper-server-start.bat ....configzookeeper.properties

第二步： 新开窗口，启动kafka
D:kafka_2.12-2.8.0inwindows>kafka-server-start.bat  ....configserver.properties

第三步： 新开窗口，测试Kafka命令
1、创建一个主题， 窗口不要关
D:kafka_2.12-2.8.0inwindows>kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic
2、查看创建的主题列表
D:kafka_2.12-2.8.0inwindows>kafka-topics.bat --list --zookeeper localhost:2181

上述两个步骤执行

第四步： 新开窗口，启动生产者
D:kafka_2.12-2.8.0inwindows>kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic

第五步： 新开窗口，启动消费者
D:kafka_2.12-2.8.0inwindows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning