赞
踩
下载地址:https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.0/kafka_2.11-2.2.0.tgz
新版本kafka内置了 zookeeper ,所有下载后解压后,不用配置。
进入解压后的主目录,地址上输入cmd回车,开启黑窗口1:
bin\windows\zookeeper-server-start.bat config\zookeeper.properties(启动zookeeper)
开启黑窗口2:
bin\windows\kafka-server-start.bat config\server.properties(启动kafka)
开启黑窗口3(创建topic topic =test ):
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
(查看创建的topic):
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
(启动producer):
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
开启黑窗口4(启动消费者 ):
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
参考:https://blog.csdn.net/w_x_s_h_h/article/details/89296088
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。