正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"group_subscribed": [ "test-consumer-group" ] } 状态码 查询成功的状态码表5所示,其他响应见表1。 表5 状态码 状态码 描述 200 查询成功。 父主题: 实例使用类接口
"message_offset": 9, "timestamp": 1568125039164 } 父主题: 实例使用类接口
"size": 6, "timestamp": 1568125036045 } } 父主题: 实例使用类接口
请求示例1 { "topic": "test", "partition": 0, "message_offset": 10 } 请求示例2 { "topic": "test", "partition": 0
"messages_count": 1, "offsets_count": 1, "offset": 1 } 父主题: 实例使用类接口
] } 状态码 查询成功的状态码如表4所示,其他响应见表1。 表4 状态码 状态码 描述 200 查询成功。 父主题: 实例使用类接口
删除Kafka消费组 Kafka实例支持通过以下两种方式删除消费组,您可以根据实际情况选择任意一种方式。 在控制台删除消费组 在Kafka客户端使用命令行工具删除消费组(确保Kafka实例版本与命令行工具版本相同) 约束与限制 若“auto.create.groups.enabl
CONSUMER-ID HOST CLIENT-ID __consumer-group-dial-test __dms_dial_test 0 350 350 0 -
请求示例 创建一个消费组,消费组名为test。 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/group { "group_name" : "test" } 响应示例 状态码: 200
图所示,此时只有“test”、“send”和“receive”用户可以订阅/发布此Topic,“send_receive”用户无法订阅/发布此Topic。 图2 为某个用户设置权限 同时设置了“默认用户”权限和单个用户权限时,取两者的并集。如下图所示,“test”和“receive”用户可以订阅+发布此Topic。
a实例的Topic名称前,形成Topic新的名称。例如当前Kafka实例别名为A,对端Kafka实例的Topic名称为test,重命名后的Topic为A.test。 Kafka数据复制的Smart Connect任务创建成功后,当前Kafka实例会自动创建“mm2-offset-syncs
响应Body参数 参数 参数类型 描述 report_id String 诊断报告ID。 请求示例 创建消费组group-test,主题topic-test的消息积压诊断任务 POST https://{endpoint}/v2/{project_id}/kafka/instan
过SSL证书进行加密传输,安全性更高。 内网IP地址 选择“自动分配”,即系统自动分配子网中可用的IP地址。 SSL用户名 用户名输入“test”,密文接入成功开启后,用户名不支持修改。 用户名需要符合以下命名规则:由英文字母开头,且只能由英文字母、数字、中划线、下划线组成,长度为4~64个字符。
查询产品规格列表 功能介绍 在创建Kafka实例时,需要配置订购的产品ID(即product_id),可通过该接口查询产品规格。 例如,要订购按需计费、基准带宽为100MB的Kafka实例,可从接口响应消息中,查找Hourly的消息体,然后找到bandwidth为100MB的记录对应的prod
xx.xx:9092,192.xx.xx.212:9092,192.xx.xx.147:9092 --list test __consumer-group-dial-test [root@ecs-kafka bin]# 已开启密文接入的Kafka实例,通过以下步骤查询消费组列表。 (可选)修改客户端配置文件。
获取项目ID 操作场景 在调用接口的时候,部分URL中需要填入项目ID,所以需要获取到项目ID。有如下两种获取方式: 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET https:
修改转储任务的配额 功能介绍 修改转储任务的配额。 2022年9月前创建的实例支持调用此接口新增转储任务配额,2022年9月及以后创建的实例,转储任务配额默认为最大值,由于转储任务配额不支持减少,调用此接口修改转储任务配额会报错。 调用方法 请参见如何调用API。 URI PUT /v2
过云监控服务的管理控制台或API接口来检索Kafka实例产生的监控指标和告警信息,也可以通过分布式消息服务Kafka版控制台提供的“监控”页面来检索Kafka实例产生的监控指标。 例如,通过API接口获取磁盘容量使用率监控指标信息,可参考API接口-查询监控数据。 命名空间 SYS
完整的状态码列表请参见状态码。 对于管理员创建IAM用户接口,如果调用后返回状态码为“201”,则表示请求成功。 响应消息头 对应请求消息头,响应同样也有消息头,如“Content-type”。 对于管理员创建IAM用户接口,返回如图1所示的消息头。 图1 管理员创建IAM用户响应消息头
10.xx.xx.127:9094,10.xx.xx.103:9094 --topic topic-demo --group order-test --from-beginning Kafka! DMS Hello ^CProcessed a total of 3 messages