canal 环境搭建 kafka Zookeeper安装

Posted 2021-03-20 shikyoh

第一步 创建Zookeeper 

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

修改 dataDir 、dataLogDir

集群模式

server.1=ServerIP:2888:3888 

第二步  创建 kafka

检查 server.properties 是否正确

 

第三步 启动 Zookeeper 和kafka

建立 bat  启动Zookeeper

cd F:DB_Brokerzookeeper-3.4.14in
zkServer.cmd
pause;

建立 bat 启动 kafka

cd F:DB_Brokerkafka_2.12-2.4.0
.inwindowskafka-server-start.bat .configserver.properties
pause;

第四步  测试 kafka 是否正常

创建 topic 

.inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

 

创建  生产者

.inwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test   

（输入 任意信息 ）

创建 消费者

.inwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning  

（是否接受正常）

 

辅助类工具

 

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

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