zookeeper
一、下载好之后在根目录添加data和log文件夹
二、将conf目录下的zoo_sample.cfg文件,复制一份,重命名为zoo.cfg,修改zoo.cfg配置文件,dataDir和dataLogDir
dataDir=E:\\ProgramFile\\apache-zookeeper-3.5.6-bin\\data
dataLogDir=E:\\ProgramFile\\apache-zookeeper-3.5.6-bin\\log
三,设置环境变量,在系统环境变量添加ZOOKEEPER_HOME名,地址是指向你的zk包地址
ZOOKEEPER_HOME:E:\ProgramFile\apache-zookeeper-3.5.6-bin
- 1> %ZOOKEEPER_HOME%\bin
- 2> %ZOOKEEPER_HOME%\conf
四、进入本地的E:\ProgramFile\apache-zookeeper-3.5.6-bin\bin
点击 zkServer.cmd 进行启动
五、如果没有闪退,打开zkServer.cmd,然后打开zkCli.cmd,证明zookeeper已经配置成功,如下图
kafka
一、编辑kafka的配置文件,E:\ProgramFile\kafka_2.12-2.7.0\config\server.properties
二、找到并编辑log.dirs=E:\ProgramFile\kafka_2.12-2.7.0\log, (自定义文件夹)
三、找到并编辑zookeeper.connect=localhost:2181。表示本地运行(默认的可以不改)
四、Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181。
//如果要修改端口号,端口号小于1024时,要用root权限启动kafka
config下
1、server.properties
port = 8100不指定的话,按照默认9092
2、connect-distributed.properties
bootstrap.servers=localhost:8100
3、producer.properties
bootstrap.servers=localhost:8100
4、connect-standalone.properties
bootstrap.servers=localhost:8100
5、consumer.properties
bootstrap.servers=localhost:8100
运行及测试
在启动Kafka前,先运行Zookeeper实例。 (前面的cmd命令:zkserver)
①启动Kafka服务器
cd E:\ProgramFile\kafka_2.12-2.7.0
.\bin\windows\kafka-server-start.bat .\config\server.properties
②创建主题
新建cmd窗口:
cd E:\ProgramFile\kafka_2.12-2.7.0\bin\windows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2
③创建生产者
新建cmd窗口:(我这边修改过端口 所以用的8100端口,默认9092!!)
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-producer.bat --broker-list localhost:8100 --topic test2
④创建消费者
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-consumer.bat --bootstrap-server localhost:8100 --topic test2 --from-beginning
**本文转自博客园“叶丶梓轩”,因为自己也需要整理一份,而且有些自己要注意的点需要添加 ** 原文链接