本文介绍: Topic rack02的partition 0分区的副本为broker2(对应的rack为2)和broker1(对应的rack为0),其中broker2为leader(在⾮rack机制下仅能消费到leader中的数据)。在上述代码中,消费者配置中限制了rack为0,消费的分区为0,因此映射到broker1。验证二:客⼾端(消费者)验证:rack机制消费者可以消费到follower副本中的数据。验证一:机架感知特性将同一分区的副本分散到不同的机架上。(3)环境准备:kafka集群。
一、kafka生产者客户端
在kafka体系结构中有如下几个重要的概念:
1、整体架构:数据发送流程
(1)生产者
二、kafka数据可靠性保证
1、LEO和HW
2、工作流程
3、Leader Epoch
三、粘性分区策略
四、机架感知
1、概念
2、机架感知分区分配策略
3、验证
(1)验证目标
(2)参数配置
broker端配置:
Client端配置:
client.rack
(3)环境准备:kafka集群
五、机架感知存在的问题
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。