赞
踩
目录
此模式实际测试效果不佳,截止3.4.1版本,其生产能力较zookeeper模式低4倍左右,消费能力较zookeeper模式低0.5倍左右。生产环境暂不建议使用。
Apache Kafka Raft (KRaft) 是为消除 Apache Kafka 对 ZooKeeper 进行元数据管理的依赖而引入的共识协议。这大大简化了 Kafka 的架构,将元数据的责任合并到 Kafka 本身,而不是将其拆分为两个不同的系统:ZooKeeper 和 Kafka。KRaft 模式在 Kafka 中使用了一个新的仲裁控制器服务,它取代了以前的控制器,并使用了 Raft 共识协议的基于事件的变体。
Apache Kafka在3.0版本中内置的KRaft共识机制取代Zookeeper。该模式在2.8版本当中就已经发布了体验版本,在3.X系列中KRaft是一个稳定release版本。
使用Zookeeper |
使用KRaft |
|
配置客户端和服务 |
zookeeper.connect=zookeeper:2181 |
bootstrap.servers=broker:9092 |
配置模式注册表 |
kafkastore.connection.url=zookeeper:2181 |
kafkastore.bootstrap.servers=broker:9092 |
Kafka管理工具 |
kafka-topics –zookeeper zookeeper:2181 |
kafka-topics –bootstrap-server broker:9092 … –command-config properties to connect to brokers |
REST 代理 API |
v1 |
v2 或 v3 |
获取 Kafka 集群 ID |
zookeeper-shell zookeeper:2181 get/cluster/id |
kafka-metadata-quorum或查看metadata.properties或confluent cluster describe –url http://broker:8090 –output json |
工具名称 |
工具版本 |
包名 |
下载地址 |
kakfa |
2.13-3.4.1 |
kafka_2.13-3.4.1.tgz |
https://kafka.apache.org/downloads |
将kafka安装包kafka_2.13-3.4.1.tgz上传至/apps目录下
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。