zookeeper

一、下载好之后在根目录添加data和log文件夹

image.png

二、将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已经配置成功，如下图

image.png

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

image.png

②创建主题

新建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

image.png

③创建生产者

新建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

image.png

**本文转自博客园“叶丶梓轩”，因为自己也需要整理一份，而且有些自己要注意的点需要添加 ** 原文链接