第一步 创建Zookeeper

下载完成后 修改 Zookeeper中的 zoo.cfg

修改 dataDir 、dataLogDir

集群模式

server.1=ServerIP:2888:3888

第二步  创建 kafka

检查 server.properties 是否正确

配置端口

listeners=PLAINTEXT://:9092

advertised.listeners=PLAINTEXT://本机IP:9092

第三步 启动 Zookeeper 和kafka

建立 bat  启动Zookeeper

cd F:\DB_Broker\zookeeper-3.4.\bin
zkServer.cmd
pause;

建立 bat 启动 kafka

cd F:\DB_Broker\kafka_2.-2.4.
.\bin\windows\kafka-server-start.bat .\config\server.properties
pause;

第四步  测试 kafka 是否正常

创建 topic

.\bin\windows\kafka-topics.bat --create --zookeeper localhost: --replication-factor  --partitions  --topic test

创建  生产者

.\bin\windows\kafka-console-producer.bat --broker-list localhost: --topic test   

(输入 任意信息 )

创建 消费者

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost: --topic test --from-beginning  

(是否接受正常)

辅助类工具

查看 Zookeeper 信息   --------------  ZooInspector

查看kafka     -----------------    kafka tool 2

05-27 21:11