检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
导出Kafka消费组列表 消费组创建成功后，可导出Kafka实例中消费组的列表信息 导出Kafka消费组列表 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
Manager中仍可以看到此消费组，是因为Kafka Manager存在缓存。 通过以下任意一种方法解决此问题： 重启Kafka Manager。 Kafka Manager只显示14天内有消费记录的消费组，如果您不想重启Kafka Manager，可以等待14天后Kafka Manager自动清除此消费组。 父主题：
"value" : 10485760 } ], "topic_desc" : "" } 响应示例 状态码： 200 创建成功，返回topic名称 { "name" : "test01" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多
topics/{topic}/partitions?start=1&limit=10 响应示例 状态码： 200 查询topic的分区列表成功 { "total" : 3, "partitions" : [ { "partition" : 0, "start_offset"
instances/{instance_id}/restart-kafka-manager 响应示例 状态码： 200 重启Manager成功。 { "result" : "success", "instance_id" : "605cd78c-92dc-4335-8bae-43677f31fd6c"
instance_id}/message-diagnosis/{report_id} 响应示例 状态码： 200 查询消息积压诊断报告详情成功 { "abnormal_item_num" : 2, "failed_item_num" : 2, "normal_item_num"
stances/{instance_id}/management/cluster 响应示例 状态码： 200 查询Kafka集群元数据信息成功。 { "cluster" : { "controller" : "2", "brokers" : [ {
es/{instance_id}/management/groups/{group} 响应示例 状态码： 200 查询实例集群的消费组信息成功。 { "group" : { "members" : [ { "host" : "/172.31.1.102",
d}/instances/{instance_id}/management/topics/{topic} 响应示例 状态码： 200 查询成功。 { "topic" : "test", "partitions" : [ { "partition" : 0,
project_id}/instances/{instance_id}/topics/diskusage 响应示例 状态码： 200 查询成功。 { "broker_list" : [ { "broker_name" : "broker-0", "data_disk_size"
Kafka实例的连通性。 显示“连通性检测成功”时，表示两端Kafka实例可以正常连接。 单击“立即创建”，跳转到Smart Connect任务列表页面，页面右上角显示“创建xxx任务成功”。 Kafka数据复制的Smart Connect任务创建成功后，当前Kafka实例会自动创建“mm2-offset-syncs
nce_id}/management/topics/{topic}/messages 响应示例 状态码： 200 查询分区指定时间段的消息成功。 { "messages" : [ { "topic" : "mytest", "partition" : 0,
创建用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交创建用户、客户端级别的流控任务，若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI POST /v2/kafka/{project_id}/instances/{instance_id}
删除用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交删除用户、客户端级别的流控任务，若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI DELETE /v2/kafka/{project_id}/instances/{instance_i
id}/instances/{instance_id}/topics?offset=0&limit=10 响应示例 状态码： 200 查询成功。 { "total" : 1, "size" : 0, "topics" : [ { "policiesOnly" :
GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码： 200 查询项目标签成功。 { "tags" : [ { "key" : "key1", "values" : [ "value-test",
"group_ids" : [ "get-sync-group0", "get-sync-group1" ] } 响应示例 状态码： 200 删除消费组成功。 { "failed_groups" : [ { "group_id" : "test-1", "error_message"
"throttle" : 10000000, "time_estimate" : false } 响应示例 状态码： 200 提交重平衡任务成功（若为预估时间任务则返回预估时间）。 { "job_id" : "8a2c259182ab0e9d0182ab1882560009",
"0e35a9f4-e75d-4fd6-b230-280860f666f7" ] } 响应示例 状态码： 200 批量删除消息积压诊断报告成功 { "results" : [ { "result" : "true", "id" : "0e35a9f4-e75d
https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags 响应示例 状态码： 200 查询实例标签成功。 { "tags" : [ { "key" : "key1", "value" : "value1" }, {
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
