你买域名我送网站,wordpress 完美搬家,浙江省2012年7月自学考试网站建设与网页设计,柳市网站制作目录 Kafka是什么#xff1f;安装 ZooKeeper下载安装启动 zookeeper 服务器端启动 zookeeper 的命令行客户端工具 安装 Kafka下载安装启动 Kafka 服务器 Kafka是什么#xff1f;
RabbitMQ的性能比ActiveMQ的性能有显著提升。
Kafka的性能比RabbitMQ的性能又有显著提升。
K… 目录 Kafka是什么安装 ZooKeeper下载安装启动 zookeeper 服务器端启动 zookeeper 的命令行客户端工具 安装 Kafka下载安装启动 Kafka 服务器 Kafka是什么
RabbitMQ的性能比ActiveMQ的性能有显著提升。
Kafka的性能比RabbitMQ的性能又有显著提升。
Kafka自称开源的、分布式事件消息、记录流框架。
Kafka官方文档一会它说事件Event、一会又说消息、一会它又说记录Record。
RabbitMQ 有官方自带的图形界面Kafka没有所以用这个第三方的CMAK。
使用Kafka需要安装的软件及安装顺序 ZooKeeper → Kafka → CMAK图形界面管理工具 安装 ZooKeeper
Kafka目前还依赖于ZooKeeper因此在安装Kafka之前需要先安装、运行ZooKeeper
下载
zookeeper-3.8.3版本
1、登录ZooKeeper官网站点下载ZooKeeper最新发行版的压缩包用最新的7-Zip解压下载得到的压缩包。 解压
安装
2、将conf/zoo_sample.cfg文件复制一份、并重命名为zoo.cfg放在同级目录下
打开zoo.cfg文件将如下配置行修改ZooKeeper的数据存储目录、ZooKeeper会自动创建该目录
dataDir/tmp/zookeeper
改为如下形式建议改成绝对路径
dataDirE:/install/ZooKeeper/workspace/zookeeper-data dataDir 是指定zookeeper的数据存储目录因为zookeeper是要管理分布式应用的多个节点这些节点的数据就存在这个dataDir 指定的地址目录里面。 zookeeper-data 这个文件夹会在启动zookeeper服务器的时候自动生成的。
路径问题注意点 我这里是已经配置好环境变量再测试的了 相对路径的情况
如果改成这种 dataDir…/zookeeper-data 相对路径的形式那么在启动zookeeper服务器的时候会报错
小黑窗输入 zkServer 绝对路径的情况 成功创建zookeeper用来存放节点数据的文件夹
3、ZooKeeper需要两个环境变量
- JAVA_HOMEZooKeeper需要Java环境因此用该环境变量指定JDK的安装路径。
- PATH将bin目录包含zkCli、zkEnv、zkServer命令添加到PATH环境变量中PATH
JAVA_HOME:
启动 zookeeper 服务器端
4、执行如下命令即可使用zoo.cfg作为配置文件来启动ZooKeeper服务。
小黑窗输入命令 zkServer默认端口2181
启动 zookeeper 的命令行客户端工具
5、ZooKeeper服务端启动之后可使用 zkCliLinux下使用zkCli.sh命令来查看节点状态就是看zookeeper客户端或者说命令行是否连接zookeeper服务端成功。 运行如下命令
小黑窗输入命令zkCli -server 127.0.0.1:2181再打开一个小黑窗
上面命令指定使用 zkCli 连接运行在 “127.0.0.1:2181” 的 ZooKeeper。
使用 zkCli 连接到 ZooKeeper服务器之后可通过ls子命令查看ZooKeeper当前的节点。看如下命令及执行结果 ls / 列出根路径下的所有节点 [zookeeper]
上面执行结果表明ZooKeeper当前只有一个zookeeper节点。
【备注】zkCli 就是 ZooKeeper 提供的命令行客户端工具可用于查看、添加、删除、修改节点等可通过help子命令来获取该工具的帮助。 安装 Kafka
下载
1、登录官网下载Kafka压缩包并解压下载得到的压缩包。
Kafka官网 Kafka 是用 Scala 语言写的Scala 是一个Java虚拟机语言。 源码是用Scala语法写的但是Scala它所编译生成出来的目标文件是class文件这个class文件可以直接在Java虚拟机平台运行。 安装
2、Kafka需要两个环境变量
- JAVA_HOMEKafka需要Java环境因此通过该环境变量指定JDK的安装路径。- PATH对于Linux平台将Kafka解压路径下bin子目录添加到PATH环境中对于Windows平台将Kafka解压路径下bin\windows子目录添加到PATH环境中。JDK 是一直都有的这里只需要添加path路径 因为后面配置好后小黑窗启动的时候出现这个问题所以重新改了路径先缩短路径长度
后面 反斜杠\ 改成 正斜杠/
3、打开config/server.properties配置文件修改如下配置行配置Kafka的数据存储目录
log.dirs/tmp/kafka-logs改为如下形式log.dirsE:/install/kafka_2.13-3.6.1/kafka-data——上面指定使用Kafka解压路径下kafka-data作为Kafka的数据存储目录日志存储目录启动 Kafka 服务器
4、启动Kafka服务器。 请注意启动Kafka服务器之前先启动ZooKeeper服务器。然后执行如下命令
kafka-server-start E:/install/kafka_2.13-3.6.1/config/server.properties该命令的参数需要指定启动Kafka所用的配置文件上面命令运行完成就代表了Kafka的第1个节点启动完成。 自动创建出这个 文件夹。这个文件夹就存放了kafka的日志文件也就是数据文件。
