dede小游戏php网站源码,中国建设银行手机银行网站,小程序后端怎么开发,企业信息查询appKAFKA基于docker使用KRaft进行集群搭建
环境#xff1a;已成功搭建kafka服务 可点击链接跳转至安装kafka-3.8.0版本 并启用SASL认证 教程
使用基于Zookeeper方式搭建集群教程
kafka-3.8.0版本 并启用SASL认证 教程
搭建kafka-ui可视化工具
192.168.2.91 192.168.2.92 192…KAFKA基于docker使用KRaft进行集群搭建
环境已成功搭建kafka服务 可点击链接跳转至安装kafka-3.8.0版本 并启用SASL认证 教程
使用基于Zookeeper方式搭建集群教程
kafka-3.8.0版本 并启用SASL认证 教程
搭建kafka-ui可视化工具
192.168.2.91 192.168.2.92 192.168.2.93
一、创建kafka集群节点192.168.2.91
1进入kafka/config/ 2修改server.properties
KRaft模式集群节点
node.id91
KRaft模式集群是否开启分区选举
auto.leader.rebalance.enabletrue
KRaft模式集群 认证授权列表
listener.security.protocol.mapCONTROLLER:PLAINTEXT,SASL_PLAINTEXT:SASL_PLAINTEXT
KRaft模式集群 监听所有连接kafka及Kraft请求
listenersSASL_PLAINTEXT://0.0.0.0:19092,CONTROLLER://0.0.0.0:19093
KRaft模式集群 第三方服务器访问kafka以及Kraft地址
advertised.listenersSASL_PLAINTEXT://192.168.2.91:19092,SASL_PLAINTEXT://172.17.0.1:19092,CONTROLLER://192.168.2.91:19093,CONTROLLER://172.17.0.1:19093
集群中当前节点角色 即可作为broker 也可作为控制器controller
process.rolesbroker,controller
集群中 互相发现的ip列表
controller.quorum.voters91192.168.2.91:19093,92192.168.2.92:19093,93192.168.2.93:19093 controller.listener.namesCONTROLLER 下图为代码中的kafka.properties
二、创建kafka集群节点192.168.2.92
1进入kafka/config/ 2修改server.properties
KRaft模式集群节点
node.id92
KRaft模式集群是否开启分区选举
auto.leader.rebalance.enabletrue
#KRaft模式集群 认证授权列表
listener.security.protocol.mapCONTROLLER:PLAINTEXT,SASL_PLAINTEXT:SASL_PLAINTEXT
KRaft模式集群 监听所有连接kafka及Kraft请求
listenersSASL_PLAINTEXT://0.0.0.0:19092,CONTROLLER://0.0.0.0:19093
KRaft模式集群 监听kafka及Kraft请求 第三方服务器访问kafka地址
advertised.listenersSASL_PLAINTEXT://192.168.2.92:19092,SASL_PLAINTEXT://172.17.0.1:19092,CONTROLLER://192.168.2.92:19093,CONTROLLER://172.17.0.1:19093
集群中当前节点角色 即可作为broker 也可作为控制器controller
process.rolesbroker,controller
集群中 互相发现的ip列表
controller.quorum.voters91192.168.2.91:19093,92192.168.2.92:19093,93192.168.2.93:19093 controller.listener.namesCONTROLLER
三、创建kafka集群节点192.168.2.93
1进入kafka_2.13-3.8.0_1/config/ 2修改server.properties
KRaft模式集群节点
node.id93
KRaft模式集群是否开启分区选举
auto.leader.rebalance.enabletrue
KRaft模式集群 认证授权列表
listener.security.protocol.mapCONTROLLER:PLAINTEXT,SASL_PLAINTEXT:SASL_PLAINTEXT
KRaft模式集群 监听所有连接kafka及Kraft请求
listenersSASL_PLAINTEXT://0.0.0.0:19092,CONTROLLER://0.0.0.0:19093
KRaft模式集群 监听kafka及Kraft请求 第三方服务器访问kafka地址
advertised.listenersSASL_PLAINTEXT://192.168.2.93:19092,SASL_PLAINTEXT://172.17.0.1:19092,CONTROLLER://192.168.2.93:19093,CONTROLLER://172.17.0.1:19093
集群中当前节点角色 即可作为broker 也可作为控制器controller
process.rolesbroker,controller
集群中 互相发现的ip列表
controller.quorum.voters91192.168.2.91:19093,92192.168.2.92:19093,93192.168.2.93:19093 controller.listener.namesCONTROLLER 下图为代码中的kafka.properties
四、配置192.168.2.91节点clientID 其中GuihyzOEQ3ulmBRdr6DVDA是我自己生成的集群ID 可通过UUID的方式自己生成
使用命令进入当前服务器的kafka容器中 1docker exec -it 容器ID bash 2cd 容器kafka/bin 3./kafka-storage.sh format -t GuihyzOEQ3ulmBRdr6DVDA -c …/config/server.properties 4重启当前kafka 容器
五、配置192.168.2.92。192.168.2.93节点clientID
内容如 四
六、验证是否成功
方式一 直接使用命令
进入容器kafka/bin,启动生产者 连接19092端口发送消息
进入其他节点的容器kafka/bin,启动消费者 接收19092端口消息可以看到其他节点发送的消息 该消费者均可接收到 方式二 使用kafka-ui
附录错误解决
如果遇到这个错误则进入 配置文件中配置 log.dirs 目录进行chmod -R 777 log.dirs设置的目录
