-
查询Smart Connect任务列表 - 分布式消息服务Kafka版
total_number Integer Smart Connector任务数。 max_tasks Integer Smart Connector最大任务数。 quota_tasks Integer Smart Connector任务配额。
-
Kafka实例创建Topic - 分布式消息服务Kafka版
partition 否 Integer topic分区数,设置消费的并发数。取值范围:1-200。 sync_replication 否 Boolean 是否开启同步复制,开启后,客户端生产消息时相应的也要设置acks=-1,否则不生效,默认关闭。
-
分布式消息服务Kafka版 - 分布式消息服务Kafka版
支持区域: 全部 创建Topic 修改Topic老化时间 修改Topic分区数 变更实例规格 Kafka实例创建成功后,您可以根据业务需要,扩容基准带宽、代理个数、存储空间、代理规格,或者缩容代理规格。 扩容存储空间有次数限制,只能扩容20次。
-
查看Kafka重平衡日志 - 分布式消息服务Kafka版
消费组订阅的Topic分区数发生变化。 约束与限制 Kafka实例扩容/缩容后,重平衡日志会自动关闭。如果需要继续使用,请重新开启。 2023年4月6日前创建的实例,不支持重平衡日志功能。
-
修改Kafka分区平衡 - 分布式消息服务Kafka版
分区平衡任务启动后,无法修改Topic的分区数。 分区平衡任务启动后,无法手动停止任务,需要等到任务完成。 已设置了一个定时分区平衡任务,在此任务未执行前,无法对本实例内的任何Topic执行其他分区平衡任务。
-
错误码 - 分布式消息服务Kafka版
Kafka实例创建Topic的分区数必须在1-20范围内。
-
查询产品规格列表 - 分布式消息服务Kafka版
partition_num String Kafka实例的最大Topic数。 product_id String 产品ID。 spec_code String 规格ID。 io Array IO信息。具体参数,请参见表6。
-
Kafka数据迁移概述 - 分布式消息服务Kafka版
创建Topic 在新的Kafka实例上创建与原Kafka实例相同配置的Topic,包括Topic名称、副本数、分区数、消息老化时间,以及是否同步复制和落盘等。具体请参考创建Kafka Topic。
-
使用客户端连接Kafka(明文接入) - 分布式消息服务Kafka版
您可以通过修改Kafka实例配置参数来修改单IP的连接数,即修改max.connections.per.ip参数值。 前提条件 已配置正确的安全组。 访问未开启密文接入的Kafka实例时,实例需要配置正确的安全组规则,具体安全组配置要求,请参考表2。
-
查询实例的扩容规格列表 - 分布式消息服务Kafka版
表7 ExtendProductPropertiesEntity 参数 参数类型 描述 max_partition_per_broker String 每个Broker的最大分区数。 max_broker String Broker的最大个数。
-
查询分区指定时间段的消息 - 分布式消息服务Kafka版
limit 否 Integer 单页返回消息数,默认值为10。 offset 否 Integer 偏移量,表示从此偏移量开始查询, offset大于等于0。 partition 否 String 分区编号,默认值为-1,若传入值为-1,则查询所有分区。
-
查询Topic的分区列表 - 分布式消息服务Kafka版
partitions objects 分区数组 表4 partitions 参数 参数类型 描述 partition Integer 分区ID start_offset Long 起始偏移量 last_offset Long 最后偏移量 message_count Long 分区消息数
-
创建Smart Connect任务 - 分布式消息服务Kafka版
(仅源端类型为Kafka时需要填写) task_num 否 Integer 数据复制的任务数。默认值为2,建议保持默认值。如果“同步方式”为“双向”,实际任务数=设置的任务数*2。
-
查询消费组信息 - 分布式消息服务Kafka版
lag Long 剩余可消费消息数,即消息堆积数。 topic String topic名称。 message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置(LEO)。
-
查询Kafka实例Topic详细信息 - 分布式消息服务Kafka版
lag Long 该副本当前落后hw的消息数。 请求示例 查询指定Topic的详细信息。
-
查询指定实例 - 分布式消息服务Kafka版
partition_num String Kafka实例的总分区数。 used_storage_space Integer 已使用的消息存储空间,单位:GB。 connect_address String 实例连接IP地址。 port Integer 实例连接端口。
-
查询消息积压诊断报告列表 - 分布式消息服务Kafka版
end_time String 诊断任务结束时间 group_name String 该次诊断任务诊断的消费组名称 topic_name String 该次诊断任务诊断的topic名称 accumulated_partitions Integer 该次诊断任务发现的存在消息堆积的分区数
-
查询所有实例列表 - 分布式消息服务Kafka版
partition_num String Kafka实例的最大topic数。 used_storage_space Integer 已使用的消息存储空间,单位:GB。 connect_address String 实例连接IP地址。 port Integer 实例连接端口。
-
查询单个转储任务 - 分布式消息服务Kafka版
lag String 积压的消息数。 请求示例 查询指定的转储任务详情。 GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks/{task_id}?
-
查询Smart Connector任务详情 - 分布式消息服务Kafka版
(仅源端类型为Kafka时会显示) task_num Integer 任务数。(仅源端类型为Kafka时会显示) rename_topic_enabled Boolean 是否重命名Topic。