二、安置zooeleeper
下载安置包:#download
下载后解压到一个目录:
1.进入Zookeeper设置目录,笔者D:\Java\Tool\zookeeper-3.4.6\conf
2. 将“zoo_sample.cfg”重定名为“zoo.cfg”
3. 在任意文本编纂器(如notepad)中打开zoo.cfg
4. 找到并编纂dataDir=D:\\Java\\Tool\\zookeeper-3.4.6\\tmp
5. 与Java中的做法类似,,我们在系统环境变量中添加:
a. 在系统变量中添加ZOOKEEPER_HOME = D:\Java\Tool\zookeeper-3.4.6
b. 编纂path系统变量,添加为路径%ZOOKEEPER_HOME%\bin;
6. 在zoo.cfg文件中改削默认的Zookeeper端口(默认端口2181)
7. 打开新的cmd,输入zkServer,运行Zookeeper。
8. 命令行提示如下:说明本地Zookeeper启动告成
三、安置与运行Kafka
下载:
。注意要下载二进制版本的
下载后解压到任意一个目录F:/kafka_2.11-0.10.0.1
1. 进入Kafka配置目录,F:/kafka_2.11-0.10.0.1
2. 编纂文件“server.properties”
3. 找到并编纂log.dirs=F:/kafka_2.11-0.10.0.1/kafka-log,这里的目录本身改削本钱身喜欢的
4. 找到并编纂zookeeper.connect=localhost:2181。暗示本地运行
5. Kafka会凭据默认,在9092端口上运行,并连接zookeeper的默认端口:2181。
运行:
重要:请确保在启动Kafka处事器前,Zookeeper实例已经筹备好并开始运行。
1.进入Kafka安置目录F:/kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.此刻输入
./bin/windows/kafka-server-start.bat ./config/server.properties
并回车
四、测试(上面的Zookeeper和kafka一直打开)
(1)、创建主题
1.进入Kafka安置目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.此刻输入
./bin/windows/kafka-console-consumer.bat --zookeeper localhost:2181 --topic helloworld
并回车
(2)创建出产者
1.进入Kafka安置目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.此刻输入
./bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic helloworld
并回车
(3)创建消费者
1.进入Kafka安置目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
3.此刻输入
./bin/windows/kafka-console-consumer.bat --zookeeper localhost:2181 --topic helloworld
并回车
然后在出产者窗口中输入内容并回车,即可在消费者窗口看到动静。