上云无忧 > 文档中心 > 腾讯云消息队列 CKafka 实战教程 - 跨可用区部署
消息队列 CKafka
腾讯云消息队列 CKafka 实战教程 - 跨可用区部署

文档简介:
CKafka 跨可用区部署: CKafka 专业版支持跨可用区部署,在拥有3个或3个以上可用区的地域购买 CKafka 实例时,可以最多选择四个可用区购买跨可用区实例。该实例分区副本会强制分布在各个可用区节点上,这种部署方式能够让您的实例在单个可用区不可用情况下仍能正常提供服务。
*此产品及展示信息均由腾讯云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

CKafka 跨可用区部署

CKafka 专业版支持跨可用区部署,在拥有3个或3个以上可用区的地域购买 CKafka 实例时,可以最多选择四个可用区购买跨可用区实例。该实例分区副本会强制分布在各个可用区节点上,这种部署方式能够让您的实例在单个可用区不可用情况下仍能正常提供服务。
说明
仅专业版支持跨可用区部署,标准版无法支持。
若需要在只有两个可用区的地域跨可用区部署,请 提交工单 申请。
CKafka 的跨可用区部署分为网络层、数据层和控制层。

网络层

CKafka 会为客户端暴露一个 VIP,客户端在连接到 VIP 后,会拿到主题分区的元数据信息(该元数据通常是地址会通过同一个 VIP 的不同 port 进行一一映射)。
是一个可以随时 failover 到另一个可用区的 VIP,当某个可用区不可用时,该 VIP 会自动漂移到该地域另一个可用的节点,从而实现跨可用区容灾。

数据层

CKafka 数据层和原生 Kafka 采用相同的分布式部署方式,即多个数据副本分布在不同 broker 节点,不同节点会部署在不同可用区。在处理某个分区时,不同的节点之间会有 leader-follower 的关系,当 leader 发生异常不在线时,集群控制节点(Controller)会选举出新的分区 leader 来承接这个分区的请求。
对于客户端来说,当某个可用区出现异常不可用后,如果某个主题分区的 leader 位于不可用区 broker 节点上,则原先建立的相关链接会出现超时或者链接被关闭的情况,当该分区 leader 节点异常之后,Controller(若 Controller 节点异常,剩余节点会竞选出新的 Controller 节点)会选举出新的leader节点提供服务,leader 切换 时间在秒级(具体切换时间与集群节点个数,元数据大小成正比)。客户端会定时刷新主题分区元数据信息,链接新的 leader 节点进行生产消费。

控制层

CKafka 的控制层和原生 Kafka 采用相同的技术方案,依赖 zookeeper 对 broker 节点进行服务发现和集群 Controller 选举。支持跨可用区部署的CKafka实例,其 zookeeper 集群中 zk 节点(以下简称 zk 节点)部署在三个可用区(或机房)。当其中任意一个可用区的 zk 节点出现故障断连,整个 zk 集群仍可以正常提供服务。

跨可用区部署优劣势

优势

可以大幅度提升集群的容灾能力,当单个可用区出现意外的网络不稳定、断电重启等不可抗力风险时,仍能保证客户端在短时间等待重连后恢复消息的生产和消费。

劣势

如果采取跨可用区部署,由于分区副本分布在多个可用区上,故消息复制相比单个可用区存在额外的跨区网络时延,该时延会直接影响到生产(客户端 Ack 参数大于1,或者等于-1, all)的客户端写入耗时。目前广州、上海、北京几个主要地域跨可用区的时延一般10ms~40ms。

跨可用区部署场景解析

单 AZ 不可用

单个 AZ 不可用后,如前文对原理的解析,客户端会出现断连重连,重连后服务仍能正常提供。
由于管控 API 服务目前不支持跨可用区部署,所以在单个 AZ 不可用之后,可能出现无法通过控制台创建 Topic,配置 ACL 策略,查看监控等现象,但不会影响存量业务的生产消费。

两个 AZ 网络隔离

如果两个 AZ 之间出现网络隔离,即无法相互通信,则可能会出现集群脑裂的现象,即两个可用区的节点都提供服务,但其中一个可用区的数据写入会在集群恢复后视为脏数据。
考虑如下场景,当集群 Controller 节点和 zk 集群一个 zk 节点与其他节点发生网络隔离。此时,其他节点会重新竞选产生新的 Controller(因为 zk 集群多数节点网络通信正常,则 Controller 可以竞选成功)但是发生网络隔离的 Controller 仍然认为自己是 Controller 节点,这时候集群会出现脑裂的情况。
此时客户端的写入需要分情况考虑,这里举个例子,当客户端的 Ack 策略等于 -1 或者 all,副本数为2时,假设集群是3节点,脑裂之后会2:1分布,原先 leader 在1节点地域的分区写入会报错,另一边则会正常写入。而一旦是3副本且配置了 Ack = -1 或者 all,则两边都不会写入成功。这时就需要根据具体参数配置来确定进一步的处理方案。
在集群网络恢复后,客户端无需做操作即可恢复生产消费,但是由于服务端会重新对数据进行归一化,其中一个分裂节点的数据会被直接截断,但对于多副本跨区的数据存储方式来说,这种截断也并不会带来数据丢失。

操作步骤

购买实例选择多个可用区

1. 登录 CKafka 控制台
2. 在左侧导航栏单击实例列表,单击新建进入实例购买页。
3. 在实例购买页,根据自身业务需求选择购买信息。
计费模式:包年包月
规格类型:根据自身业务需求选择标准版或者专业版。
Kafka 版本:根据您的业务需求选择 Kafka 版本,可参见 CKafka 版本选择建议
地域:选择和部署客户端的资源相近的地域。
可用区:根据实际需要选择可用区。
标准版:不支持多可用区部署。
专业版:若当前地域支持多可用区部署,则最多可选择4个可用区进行部署。关于跨可用区部署原理介绍请参见 跨可用区部署
产品规格:根据峰值带宽和磁盘容量选择对应的型号。
消息保留:范围在24小时 - 2160小时。 在磁盘容量不足(即磁盘水位达到90%)时,将会提前删除旧的消息,以确保服务可用性。
私有网络:若用户需要接入其他私有网络可参见 添加路由策略 修改路由接入规则。
标签:选填,具体使用方法可参见 标签管理
实例名称:购买多个实例时,支持创建实例后缀数字自动升序以及指定模式串功能。具体操作参见 批量连续命名或指定模式串命名
4. 单击立即购买,完成实例创建。
相似文档
  • 本文主要介绍消息队列 CKafka 版生产和消费消息的最佳实践,帮助您减少消费消息出错的可能性。
  • 简介: 您可以将日志主题的数据投递到腾讯云 Ckafka,然后用于您的实时流计算、或者入库等场景。如果您没有购买腾讯云 Ckafka 实例,可以考虑使用日志服务(Cloud Log Service,CLS)自带的 Kafka 协议消费功能。
  • 操作场景: 日志采集功能是容器服务 TKE 为用户提供的集群内日志采集工具,可以将集群内服务或集群节点特定路径文件的日志发送至 腾讯云日志服务 CLS、消息队列 CKafka 版。日志采集功能适用于需要对 Kubernetes 集群内服务日志进行存储和分析的用户。
  • 日志分析可查看基于登录账号的云防火墙在过去6个月所存储的全部流量日志详情,同时日志分析支持基于检索语句的日志检索与查询,并提供报表与统计分析服务。本文档将为您介绍如何使用日志分析功能。
  • 日志审计为您提供云上的统一安全日志审计与检索调查平台,包含主机安全告警、Web 应用防火墙告警、DDoS 防护告警、云防火墙告警、SaaS 型堡垒机告警、传统型堡垒机告警、安全运营中心告警和网络入侵检测告警等安全相关日志数据,您可根据实际不同安全场景按需进行检索调查和日志投递。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部