赞
踩
启动 ZooKeeper 单机版,详细步骤略。
http://kafka.apache.org/downloads
下载的是 kafka_2.11-2.2.0.tgz
解压 kafka_2.11-2.2.0.tgz 到 D:\develop_tools\kafka\kafka_2.11-2.2.0
修改 server.properties 中的
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
在 D:\develop_tools\kafka\kafka_2.11-2.2.0\bin\windows
目录,打开新窗口,输入命令:
kafka-server-start.bat ..\..\config\server.properties
如图所示:
在 D:\develop_tools\kafka\kafka_2.11-2.2.0\bin\windows
目录,打开新窗口,
创建一个名称为 test
主题,命令如下:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
如图所示:
在 D:\develop_tools\kafka\kafka_2.11-2.2.0\bin\windows
目录,打开新窗口,输入命令:
kafka-topics.bat --list --zookeeper localhost:2181
在 D:\develop_tools\kafka\kafka_2.11-2.2.0\bin\windows
目录,打开新窗口,输入命令:
kafka-console-producer.bat --broker-list localhost:9092 --topic test
在 D:\develop_tools\kafka\kafka_2.11-2.2.0\bin\windows
目录,打开新窗口,输入命令:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
在 生产者 窗口输入数据,在 消费者 接收到数据
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。