-
查询单个转储任务 - 分布式消息服务Kafka版
转储任务名称。 destination_type String 转储任务类型。 create_time Long 转储任务创建时间戳。 status String 转储任务状态。 topics String 返回任务转存的topics列表或者正则表达式。 obs_destination_descriptor
-
使用前必读 - 分布式消息服务Kafka版
ion。 可用区(AZ,Availability Zone) 一个可用区是一个或多个物理数据中心的集合,有独立的风火水电,AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ间通过高速光纤相连,以满足用户跨AZ构建高可用性系统的需求。 项目 区域默认
-
错误码 - 分布式消息服务Kafka版
page for pagination query exceeds the upper limit. 分页查找的分页大小超出范围。 请检查分页大小 400 DMS.10240043 The number of skipped records for pagination query exceeds
-
删除Kafka消息 - 分布式消息服务Kafka版
在左侧导航栏选择“Topic管理”,进入Topic列表页面。 执行以下步骤,弹出“消息删除”对话框。 如果实例未开启密文接入功能,在待删除消息的Topic所在行,单击“消息删除”。 如果实例已开启密文接入功能,在待删除消息的Topic所在行,单击“更多 > 消息删除”。 设置消息删除参数,如表1所示。
-
查询消费组信息 - 分布式消息服务Kafka版
balance。 CompletingRebalance:所有成员加入group。 Stable:消费组内成员可正常消费。 coordinator_id Integer 协调器编号 members Array of object members 消费者列表。参数参见表3。 group_message_offsets
-
制作和替换Kafka的SSL证书 - 分布式消息服务Kafka版
按照提示信息输入证书拥有者的信息,如姓名、单位、所在城市等。 执行以下命令,创建CA的认证证书。 openssl req -new -x509 -keyout ca-key -out ca-cert -days 3650 按照提示信息输入PEM密码。 按照提示信息输入证书拥有者的信息。 执行以下命令,通过CA创建一个
-
Kafka数据迁移概述 - 分布式消息服务Kafka版
步骤请参见查看Kafka消息。 是,执行3。 否,在监控页面查看两个Kafka的“Kafka每分钟同步数据量”是否正常,如果正常,先等待两个Kafka的同步进度一致,然后执行3。 将消费客户端的Kafka连接地址修改为新Kafka实例的连接地址。 重启消费业务,使得消费者从新Kafka实例中消费消息。
-
查询所有消费组 - 分布式消息服务Kafka版
balance。 CompletingRebalance:所有成员加入group。 Stable:消费组内成员可正常消费。 coordinator_id Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 查询消费组列表。
-
配置Kafka间的数据复制 - 分布式消息服务Kafka版
Connect任务的名称,用于区分不同的Smart Connect任务。 在“预置类型”中,选择“Kafka数据复制”。 在“立即执行”中,选择任务创建后是否立即执行任务,默认开启立即执行。如果关闭,在需要执行此任务时,您可以在Smart Connect任务列表中手动开启任务。 在“当前kafka”区域,设置实例别名。
-
Kafka消息堆积了怎么办? - 分布式消息服务Kafka版
选择需要诊断的消费组名称和Topic名称,单击“诊断前检查”。 诊断前检查成功后,如果“消息积压情况”显示有消息积压,并且消费组正在以非assign方式消费消息中,单击“开始诊断”。 诊断成功后,在诊断记录所在行,单击“查看详情”,进入“诊断详情”页面,查看导致消息堆积的可能原因、受影响的分区或者broker
-
配置Kafka实例的公网访问 - 分布式消息服务Kafka版
在“公网访问”后,单击,开启公网访问。在“弹性IP地址”中,为每个代理设置对应的弹性IP地址。如果没有足够数量的弹性IP地址,单击“创建弹性IP”,跳转到“购买弹性公网IP”页面,购买弹性IP地址,具体操作请参考申请弹性公网IP。购买完成后,返回开启公网页面。单击“弹性IP地址”后的,然后在下拉框中选择和代理数量相同的弹性IP地址,单击。
-
关闭Smart Connect - 分布式消息服务Kafka版
前提条件 已创建Kafka实例,且实例状态为“运行中”。 关闭Smart Connect前,请先删除所有的Smart Connect任务,否则无法关闭Smart Connect。此操作是为了防止关闭Smart Connect导致正在运行的Smart Connect任务丢失。 关闭Smart
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
重置消费组消费进度到指定位置 功能介绍 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前,必须停止被重置消费组客户端。停止待重置消费组客户端,然后等待一段时间(即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间,默认为1000
-
创建Smart Connect任务 - 分布式消息服务Kafka版
g{ ConsumerStrategy: &consumerStrategySinkTask, DestinationFileType: &destinationFileTypeSinkTask, DeliverTimeInterval: &deliverTimeIntervalSinkTask
-
查看Kafka审计日志 - 分布式消息服务Kafka版
开启Smart Connect任务执行成功 kafka createConnectorTaskSuccess 创建Smart Connect任务执行成功 kafka createConnectorSinkTaskSuccess 开启Smart Connect任务执行失败 kafka cre
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
当前页面API为历史版本API,未来可能停止维护。请使用重置消费组消费进度到指定位置。 功能介绍 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前,必须停止被重置消费组客户端。停止待重置消费组客户端,然后等待一段时间(即ConsumerConfig.SESSION_T
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
当前页面API为历史版本API,未来可能停止维护。请使用重置消费组消费进度到指定位置。 前提条件 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前,必须停止被重置消费组客户端。 在停止被重置消费组客户端后,需要经过ConsumerConfig.SESSION_TIME
-
升级Kafka实例内核版本 - 分布式消息服务Kafka版
在待升级内核版本的Kafka实例所在行,选择“更多 > 升级”,弹出“版本升级”对话框。 如果Kafka实例内核版本已经是最新,控制台不显示“更多 > 升级”功能。 选择执行时间,支持“立即执行”和“定时执行”。 如果选择“定时执行”,还需要指定执行时间。 在“风险检查”区域,查看升级前的检查项是否正常。
-
分布式消息服务Kafka版 - 分布式消息服务Kafka版
连接已开启SASL的Kafka实例 跨VPC访问Kafka实例 使用DNAT访问Kafka实例 Topic管理 Topic,即消息主题。创建Kafka实例后,如果没有开启“kafka自动创建Topic”,需要手动创建Topic,然后才能进行生产消息和消费消息。 创建Topic后,您可以根据业务需要修改Topic的老化时间。
-
停止计费 - 分布式消息服务Kafka版
删除”,对Kafka实例执行删除操作,确保列表中已无该资源。 按需计费资源删除后,可能还会存在账单信息,因为系统通常会在使用后1个小时内对上一个结算周期的费用进行扣款。例如在8:30删除按小时结算的Kafka实例,但是8:00~9:00期间产生的费用,通常会在10:00左右才进行扣费。