赞
踩
常见安装:zookeeper + kafka
zookeeper 单节点安装 :
- apach官网下载对应包:apache-zookeeper-3.7.1-bin.tar.gz
- 修改对应配置文件 /conf/zoo_sample.cfg ,配置端口以及数据目录
sh zkServer.sh start
启动 、sh zkServer.sh
stop 停止、sh zkServer.sh status
状态sh zkCli.sh -server
客户端
zookeeper 集群安装:
- 在每个节点data 目录,创建一个 myid 的文件,myid内容为服务id,没个节点服务id不同
- 配置文件
zoo.cfg
添加集群信息:server.myid=ip:2888:3888
- 2888为 服务器 follower 与集群leader 的通信端口、3888 leader挂掉后,选举用端口
- 各节点启动集群.
- 分布式框架提供协调服务,为kafak 管理员,需要 zookeeper
选择机制
、节点监听
等
- 集群管理、leader选举
- Topic注册
- Broker注册
- zookeeper 存储 kafka 的 borker信息,topic等 信息
kafka 集群安装:
- https://kafka.apache.org/ 官网下载对应运行体,eg:kafka_2.12-3.0.0.tgz
- config/
server.properties
修改对应服务配置
broker.id
服务唯一idlog.dirs=/tmp/kafka-logs
数据目录zookeeper.connect
=192.168.2.207:2181,192.168.2.208:2181/kafka 集群地址配置- 各节点启动 : sh kafka-server-start.sh -daemon …/config/server.properties
kafka -
Kraft
模式(去掉zookeeper)
- 版本大于
2.8.0
时,可以不依赖zookeeper 环境启动
- 修改
krafk
目录下 server.properties 配置文件,以下操作每个节点需要同步配置,node.id
为唯一
- 生成一个随机id:
sh kafka-storage.sh random-uuid
- 初始化:
sh kafka-storage.sh format -t ${id} -c /opt/kafka/kafka_2.12-3.0.0/config/kraft/server.properties
-Kraft 模式启动:sh ./bin/kafka-server-start.sh -daemon ./config/kraft/server.properties
Kraft 模式 以及 安全认证配置:
SASL/GSSAPI
:kerberos认证方式,一般使用随机密码的keytab认证方式,密码是加密的,也是企业里使用最多的认证方式;SASL/PLAIN
:这种方式其实就是一个账号/密码的认证方式,不过它有很多缺陷,比如用户名密码是存储在文件中,不能动态添加,密码明文等等!好处是足够简单;SASL/SCRAM
:针对SASL/PLAIN方式的不足而提供的另一种认证方式。这种方式的用户名/密码是存储中zookeeper的,因此能够支持动态添加用户。该种认证方式还会使用sha256或sha512对密码加密,安全性相对会高一些,在0.10.2版本引入;
SASL/PLAIN 安全认证配置 :
- 新建config 文件
config/kafka_server_jaas.conf
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/你好赵伟/article/detail/700479
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。