canal 环境搭建 kafka Zookeeper安装(二)
2024-09-08 04:14:43
第一步 创建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
最新文章
- 找回Reshaprer的Alt+Enter快捷键的方法
- struts2加入自定义的actionValidatorManager实现类
- [Stephen]Android的adb无法启动
- CI 笔记3 (easyui 和 js 排错)
- 栈和队列的面试题Java实现
- C#委托 Lamda表达式
- 关于运行robotium提示连接不上jar问题
- M、V、C
- 【java学习】Servlet简单的表单程序(一)
- Excel公式-求最低价网站名字
- 阿里聚安全移动安全专家分享:APP渠道推广作弊攻防那些事儿
- HTTP错误代码大全
- 解决由于VNC日志导致服务器磁盘100%
- error_reporting
- Hama安装及示例运行
- 第一节: 结合EF的本地缓存属性来介绍【EF增删改操作】的几种形式
- js如何获得局部变量的值
- 犯罪心理第一季/全集Criminal Minds迅雷下载
- 【比特币】SPV是如何工作的
- Excel只能输入不许修改