检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 1 2
可以为不同的用户设置不同的访问Kafka实例的权限,以达到不同用户之前的权限隔离。 云监控(Cloud Eye) 云监控是一个开放性的监控平台,提供资源的实时监控、告警、通知等服务。 Kafka实例向CloudEye上报监控数据的更新周期为1分钟。 弹性公网IP(Elastic IP)
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 创建一个稍后启动的Kafka数据复制任务。
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 老规格按需实例的开启Smart
"sasl_enabled_mechanisms" : [ "SCRAM-SHA-512", "PLAIN" ] } 响应示例 无 状态码 状态码 描述 200 提交修改Kafka接入方式成功。 错误码 请参见错误码。 父主题: 实例管理
"67fc5f8d-3986-4f02-bb75-4075a23112de" } ] } 状态码 操作成功的状态码如表5所示,其他响应见状态码。 表5 状态码 状态码 描述 200 重启或者删除实例成功。 204 删除创建失败实例成功。 父主题: 实例管理类接口
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 扩容代理数量(按需实例)。
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 创建一个包年包月的Kafka实例,版本为2
1.15", "port": 9092 } ] } 状态码 查询成功的状态码如表4所示,其他响应见表1。 表4 状态码 状态码 描述 200 查询成功。 父主题: 实例使用类接口
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 批量删除实例。
"false", "sync_message_flush": "false" } ] } 状态码 操作成功的状态码如表4所示,其他响应见状态码。 表4 状态码 状态码 描述 200 查询成功。 父主题: 实例管理类接口
"name": "1" }, { "name": "2" }] }] }] } 状态码 查询成功的状态码如表11所示,其他响应见表1。 表11 状态码 状态码 描述 200 查询成功。 父主题: 其他接口
参数 类型 说明 id String topic名称 响应示例 { "id": "haha" } 状态码 操作成功的状态码如表4所示,其他响应见状态码。 表4 状态码 状态码 描述 200 创建成功。 父主题: 实例管理类接口
"maintain_end":"06:00:00" } 响应消息 响应参数 无。 响应样例 无。 状态码 操作成功的状态码如表3所示,其他响应见状态码。 表3 状态码 状态码 描述 204 修改实例成功。 父主题: 实例管理类接口
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 创建一个用户,用户名为test,密码为Cxxx3。
使用控制台连接Kafka 本章节介绍Kafka实例如何在控制台生产消息。此功能通过将指定消息发送给Kafka实例,验证业务逻辑是否正常。 前提条件 仅在实例的“状态”为“运行中”时,才可以在Topic中生产消息。 已创建Topic。 在控制台生产消息 登录管理控制台。 在管理控制
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 1 2
身份认证与访问控制 身份认证 无论用户通过控制台还是API访问DMS for Kafka,都会要求访问请求方出示身份凭证,并进行身份合法性校验,同时提供登录保护和登录验证策略加固身份认证安全。 DMS for Kafka基于统一身份认证服务(Identity and Access
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 1 2
ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 1 2