检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"assignment": [ { "topic": "test", "partitions": [
请求示例 创建一个消费组,消费组名为test。 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/group { "group_name" : "test" } 响应示例 状态码: 200
为什么删除消费组不生效? 可能原因:您开启了自动创建消费组功能,且您的业务正在连接该消费组消费消息。所以,如果没有停止您的业务,删除了消费组后,消费消息时还是会自动创建该消费组。 解决办法:关闭自动创建消费组功能,即在Kafka控制台的“配置参数”页面,把“auto.create
"message_offset ": 9, "timestamp": 1568125039164 } 父主题: 实例使用类接口
响应消息 响应参数 无 响应示例 无 状态码 操作成功的状态码。 表3 状态码 状态码 描述 204 新增分区操作成功。 父主题: 实例使用类接口
"name": "1" }, { "name": "2" }] }], "groups": [{ "name": "test-consumer-group", "queues": [{ "name": "mytest", "partitions":
"isr_replicas_count": 21, "consumers_count": 7 } } 父主题: 实例使用类接口
"message_offset": 9, "timestamp": 1568125039164 } 父主题: 实例使用类接口
"group_subscribed": [ "test-consumer-group" ] } 状态码 查询成功的状态码表5所示,其他响应见表1。 表5 状态码 状态码 描述 200 查询成功。 父主题: 实例使用类接口
"size": 6, "timestamp": 1568125036045 } } 父主题: 实例使用类接口
响应消息 响应参数 无 响应示例 无 状态码 操作成功的状态码。 表4 状态码 状态码 描述 204 调整副本操作成功。 父主题: 实例使用类接口
新增诊断管理相关接口。 2024-03-06 本次变更如下: 新增Smart Connect相关接口。 将转储相关接口移动至历史API。 2024-02-26 本次变更如下: 新增生产消息接口。 2023-11-10 本次变更如下: 新增获取实例配置和修改实例配置接口。 2023-07-26
响应Body参数 参数 参数类型 描述 report_id String 诊断报告ID。 请求示例 创建消费组group-test,主题topic-test的消息积压诊断任务 POST https://{endpoint}/v2/{project_id}/kafka/instan
producer.py 运行成功后,返回如下回显。 [root@ecs-test ~]# python3 producer.py start producer end producer [root@ecs-test ~]# 消费消息 在客户端创建一个文件,用于存放消费消息的代码示例。
请求示例1 { "topic": "test", "partition": 0, "message_offset": 10 } 请求示例2 { "topic": "test", "partition": 0
"messages_count": 1, "offsets_count": 1, "offset": 1 } 父主题: 实例使用类接口
修改转储任务的配额 功能介绍 修改转储任务的配额。 2022年9月前创建的实例支持调用此接口新增转储任务配额,2022年9月及以后创建的实例,转储任务配额默认为最大值,由于转储任务配额不支持减少,调用此接口修改转储任务配额会报错。 调用方法 请参见如何调用API。 URI PUT
在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 在开始使用之前,请确保您安装的是最新版本的SDK。使用过时的版本可能会导致兼容性问题或无法使用最新功能。您可以在SDK中心查询版本信息。 表1提供了分布式消息服务K
] } 状态码 查询成功的状态码如表4所示,其他响应见表1。 表4 状态码 状态码 描述 200 查询成功。 父主题: 实例使用类接口
客户端可以使用公网通过IPv4地址或者IPv6地址访问Kafka实例。 IPv4地址:在Kafka控制台开启实例的公网访问功能,并设置弹性IP地址,实现公网访问。 IPv6地址:在创建Kafka实例时开启IPv6功能,然后将IPv6地址添加到共享带宽中,同时支持IPv6内网访问和IPv6公网访问。 Kafka控制台的“基本信息