-
修改Kafka实例Topic分区的副本 - 分布式消息服务Kafka版
58 59 60 61 62 63 64 65 66 67 68 69 70 71 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud
-
查询所有实例列表 - 分布式消息服务Kafka版
} 状态码 操作成功的状态码如表5所示,其他响应见状态码。 表5 状态码 状态码 描述 200 查询所有实例列表成功。 父主题: 实例管理类接口
-
调整Kafka实例Topic分区的副本 - 分布式消息服务Kafka版
响应消息 响应参数 无 响应示例 无 状态码 操作成功的状态码。 表4 状态码 状态码 描述 204 调整副本操作成功。 父主题: 实例使用类接口
-
修改Kafka分区平衡 - 分布式消息服务Kafka版
在“后台任务管理”页面的“定时任务”页签中,单击页面左上角下拉框,选择时间段,在搜索对话框中输入待修改定时分区平衡任务的Topic名称,按“Enter”,实现快速查找定时分区平衡任务。 图5 查找定时分区平衡任务 在待修改的定时分区平衡任务后,单击“修改”。 在弹出的“修改定时任务”对话框中,您可以修改定时分区平衡
-
查询可用区信息 - 分布式消息服务Kafka版
查询可用区信息 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 region_id
-
查询可用区信息 - 分布式消息服务Kafka版
查询可用区信息 当前页面API为历史版本API,未来可能停止维护。请使用查询可用区信息。 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 URI GET /v1.0/availableZones 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1
-
Python - 分布式消息服务Kafka版
本文以Linux CentOS环境为例,介绍Python版本的Kafka客户端连接指导,包括Kafka客户端安装,以及生产、消费消息。 使用前请参考收集连接信息收集Kafka所需的连接信息。 准备环境 Python 一般系统预装了Python。在命令行输入python,得到如下回显,说明Python已安装。
-
Kafka实例批量删除Topic - 分布式消息服务Kafka版
Kafka实例批量删除Topic 当前页面API为历史版本API,未来可能停止维护。请使用Kafka实例批量删除Topic。 功能介绍 该接口用于向Kafka实例批量删除Topic。 URI POST /v1.0/{project_id}/instances/{instance_id}/topics/delete
-
API概览 - 分布式消息服务Kafka版
API概览 表1 实例管理类接口 API 说明 生命周期管理 包括创建实例、查询所有实例列表、查询指定实例、删除指定的实例、修改实例信息、批量重启或删除实例、获取实例配置、修改实例配置。 实例管理 包括重置密码、重置Manager密码、重启Manager、开启或关闭实例自动创建T
-
其他接口 - 分布式消息服务Kafka版
其他接口 查询可用区信息 查询产品规格列表 查询维护时间窗时间段 查询实例在CES的监控层级关系 父主题: API V1
-
Kafka实例批量删除Topic - 分布式消息服务Kafka版
Kafka实例批量删除Topic 功能介绍 该接口用于向Kafka实例批量删除Topic。批量删除多个Topic时,部分删除成功,部分失败,此时接口返回删除成功,并在返回中显示删除失败的Topic信息。 调用方法 请参见如何调用API。 URI POST /v2/{project
-
其他接口 - 分布式消息服务Kafka版
其他接口 查询维护时间窗时间段 查询可用区信息 查询产品规格列表 查询实例在CES的监控层级关系 父主题: API V2(推荐)
-
查询指定实例 - 分布式消息服务Kafka版
对于同一个实例,Key值唯一。 长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_
-
设置用户权限 - 分布式消息服务Kafka版
error_code String 错误码。 error_msg String 错误描述。 请求示例 设置用户权限,为root用户授予发布和订阅topic-test的权限。 POST https://{endpoint}/v1/{project_id}/instances/{instance_id}
-
购买Kafka实例 - 分布式消息服务Kafka版
ka实例的版本号、代理规格、代理数量、磁盘类型和存储空间。集群版实例支持Kafka 1.1.0、2.7和3.x版本。 规格测算:系统根据您输入的参数(生产流量峰值、消费流量、单个Topic副本数、总分区数和老化时间内的生产消息量),为您计算出不同规格所需的代理个数和代理存储空间,您根据实际情况选择。
-
使用DNAT实现公网访问Kafka - 分布式消息服务Kafka版
步骤五:验证接口连通性 参考使用客户端连接Kafka(明文接入)或者使用客户端连接Kafka(密文接入),测试是否可以生产和消费消息。 测试接口连通性时,注意以下几点: 连接Kafka实例的地址为“advertised.listeners IP:9011”,以图6为例,连接Kafka实例的地址为“124
-
实例使用类接口 - 分布式消息服务Kafka版
实例使用类接口 查询分区指定偏移量的消息 查询分区指定时间段的消息 查询分区最新消息的位置 查询分区最早消息的位置 查询Kafka集群元数据信息 查询消费组信息 重置消费组消费进度到指定位置 查询Kafka实例所有消费组对应的协调器信息 查询Kafka实例Topic详细信息 新增Kafka实例指定Topic分区
-
查询用户权限 - 分布式消息服务Kafka版
s/{topic_name}/accesspolicy 响应示例 状态码: 200 查询成功。 { "name" : "topic-test", "policies" : [ { "owner" : false, "user_name" : "xxxa",
-
实例管理类接口 - 分布式消息服务Kafka版
实例管理类接口 创建Kafka实例 查询指定实例 修改实例信息 删除指定实例 批量重启、删除实例 查询所有实例列表 Kafka实例创建Topic Kafka实例查询Topic Kafka实例批量删除Topic 父主题: API V1
-
查询产品规格列表 - 分布式消息服务Kafka版
33 34 35 36 37 38 39 40 41 42 43 44 45 46 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud