基本环境
- JDK8
zookeeper下载和安装
下载
下载地址 https://www.apache.org/dyn/closer.cgi/zookeeper/
安装配置:
- 解压
- 环境变量
ZOOKEEPER_HOME设置为解压或zookeeper的bin目录 - 复制一份
zoo_sample.cfg 为zoo.cfg -
zoo.cfg修改dataDir=D:\\data\\zoo,D:\data\zoo是我新建的文件夹
启动
- 打开cmd,进入zookeeper的bin目录
> .\zkServer.cmd
kafka 下载安装
安装配置
- 解压
- 配置
config/zookeeper.properties#line 31后添加
listeners= PLAINTEXT://localhost:9092
启动
进入bin目录
> bin\windows\kafka-server-start.bat config\server.properties
添加topic (主题)
> >bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic yourTopicName