检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
用户名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 new_password 否 String 用户新密码。 重置用户密码时,为必选参数; 不能与名称或倒序的名称相同。 复杂度要求: 输入长度为8到32位的字符串。 必须包含如下四种字符中的三种组合: 小写字母
是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例id 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/management
instance_id 是 String 实例ID。 task_id 是 String Smart Connect任务ID。 请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/co
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询项目标签成功。 错误码 请参见错误码。 父主题:
instance_id 是 String 实例ID。 task_id 是 String Smart Connector任务ID。 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/c
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询成功。 错误码 请参见错误码。 父主题: 其他接口
connector_id 是 String 实例转储ID。 请参考查询实例返回的数据。 task_id 是 String 转储任务ID。 请求参数 无 响应参数 无 请求示例 删除指定的转储任务。 DELETE https://{endpoint}/v2/{project_id}/conn
客户端单IP连接的个数为多少? 连接Kafka Manager的操作 更多 消息 为什么Console页面上,消息查询查不到消息? Kafka生产消息的最大长度是多少? Kafka消息堆积了怎么办? 消息拉取失败的原因 更多 智能客服 您好!我是有问必答知识渊博的智能问答机器人,有问题欢迎随时求助哦!
创建用户 功能介绍 创建Kafka实例的用户,用户可连接开启SASL的Kafka实例。 2023年7月15日前创建的Kafka实例,一个实例最多创建20个用户。2023年7月15日及以后创建的Kafka实例,一个实例最多创建500个用户。 调用方法 请参见如何调用API。 URI
engine 是 String 消息引擎的类型。 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 user_name 是 String 用户名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型
在创建kafka实例时,需要配置订购的产品ID(即product_id),可通过该接口查询产品规格。 例如,要订购按需计费、基准带宽为100MB的kafka实例,可从接口响应消息中,查找Hourly的消息体,然后找到bandwidth为100MB的记录对应的product_id,该product_id的值即是
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 批量删除消息积压诊断报告成功 错误码 请参见错误码。
instance_id 是 String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 job_id String 返回异步执行删除任务的job id。 请求示例 POST https://{endpoint}/v2/{projec
转储任务创建时间戳。 status String 转储任务状态。 topics String 返回任务转存的topics列表或者正则表达式。 请求示例 查询转储任务列表。 GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks
成,长度为4~64的字符。 user_desc String 用户描述。 role String 用户角色。 default_app Boolean 是否为默认应用。 created_time Long 创建时间。 请求示例 查询用户列表。 GET https://{endpoi
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询实例标签成功。 错误码 请参见错误码。 父主题:
务端能够理解用户请求,但是拒绝做更多的事情,因为该请求被设置为拒绝访问,建议直接修改该请求,不要重试该请求。 404 NotFound 所请求的资源不存在。 建议直接修改该请求,不要重试该请求。 405 MethodNotAllowed 请求中带有该资源不支持的方法。 建议直接修改该请求,不要重试该请求。
String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 result String 执行结果。 instance_id String 实例ID。 请求示例 重启Kafka Manager。 PUT https://{endpoi
示按照实例名称进行精确匹配查询。 enterprise_project_id String 否 企业项目ID。 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/{project_id}/instances?start=1&lim
参数类型 描述 action_id 是 String 动作ID,生产消息对应的action_id为send。 请求参数 表3 请求Body参数 参数 是否必选 参数类型 描述 topic 是 String Kafka的topic body 是 String 消息内容 property_list