嘉兴网站建设推荐浙江华企,宁波电商平台网站建设,平江网页设计报价,网站 设计 方案安装kafka需要jdk和zookeeper环境#xff0c;因此先部署单机zk的测试环境。 zookeeper离线安装
下载地址#xff1a;
zookeeper下载地址#xff1a;Index of /dist/zookeeper 这里下载安装 zookeeper-3.4.6.tar.gz 版本#xff0c;测试环境单机部署
上传服务器后解压缩 …安装kafka需要jdk和zookeeper环境因此先部署单机zk的测试环境。 zookeeper离线安装
下载地址
zookeeper下载地址Index of /dist/zookeeper 这里下载安装 zookeeper-3.4.6.tar.gz 版本测试环境单机部署
上传服务器后解压缩
tar -zxvf zookeeper-3.4.6.tar.gz
sudo mv zookeeper-3.4.6 /usr/local/zookeeper
配置conf文件
Zookeeper 在启动时会找zoo.cfg这个文件作为默认配置文件。
# 进入安装目录的…/conf目录下
cd conf/# 复制样例文件
cp zoo_sample.cfg zoo.cfg# 修改配置文件
vi zoo.cfg# zookeeper内部的基本单位单位是毫秒这个表示一个tickTime为2000毫秒在zookeeper的其他配置中都是基于tickTime来做换算的
tickTime2000#集群中的follower服务器(F)与leader服务器(L)之间 初始连接 时能容忍的最多心跳数tickTime的数量。
initLimit10#syncLimit集群中的follower服务器(F)与leader服务器(L)之间 请求和应答 之间能容忍的最多心跳数tickTime的数量
syncLimit5# 数据存放文件夹zookeeper运行过程中有两个数据需要存储一个是快照数据持久化数据另一个是事务日志
dataDir/data/zookeeper/data# 客户端访问端口
clientPort2181启动zk
# 启动服务
sh /usr/local/zookeeper/bin/zkServer.sh start# 查看服务状态
sh /usr/local/zookeeper/bin/zkServer.sh status# 测试客户端连接
sh /usr/local/zookeeper/bin/zkCli.sh启动后查看zk状态 zookeeper参考文章
【zookeeper安装】zookeeper安装详细教程单机/集群部署linux版-CSDN博客
zookeeper 单机版 zookeeper单机安装_蓝月亮的技术博客_51CTO博客
kafka安装
官网下载安装包
https://kafka.apache.org/downloads.html 注kafka需要安装zookeeper使用
上传安装包解压文件
tar -zxvf kafka_2.12-2.7.2.tgz
sudo mv kafka_2.12-2.7.2 /usr/local/kafka
修改配置文件 vim server.properties
添加或修改如下信息:#broker的全局唯一编号不能重复broker.id0#用来监听链接的端口producer或consumer将在此端口建立连接listenersPLAINTEXT://localhost:9092#kafka消息存放的路径log.dirs/data/kafka/logs#broker需要使用zookeeper保存meta数据zookeeper.connectlocalhost:2181
启动kafka
前台运行
sh bin/kafka-server-start.sh ./config/server.properties后台运行
sh bin/kafka-server-start.sh -daemon ./config/server.properties创建topic
创建测试test的topic
sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看topic list
sh bin/kafka-topics.sh --list --zookeeper localhost:2181生产消息
sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test消费消息
sh bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test
从0开始消费所有消息
sh bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning kafka参考文章
Kafka最全单机安装完整步骤加测试_kafka单机安装-CSDN博客
kafka和zookeeper安装 - 蜂蜜log - 博客园
