检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Message ack status must be either 'success' or 'fail'. It should not be '{status}'. 消息确认status字段值必须为'success'或'fail',目前为 {status}。 请检查请求字段status是否不符合要求
限速,单位为KB/s。-1表示不限速(仅源端类型为Redis时会显示) current_cluster_name String 当前Kafka实例别名。(仅源端类型为Kafka时会显示) cluster_name String 对端Kafka实例别名。(仅源端类型为Kafka时会显示)
}/restart-kafka-manager 响应示例 状态码:200 重启Manager成功。 { "result" : "success", "instance_id" : "605cd78c-92dc-4335-8bae-43677f31fd6c" } SDK代码示例
群的监控、代理等信息。 集群信息页 单击Clusters中的集群列表,即可进入集群信息页。如图3所示。 图中①区域表示功能导航栏。 Cluster:集群,统计集群列表和集群详情。 Brokers:代理,统计当前集群中各代理的状态信息。 Topic:队列,统计当前集群中的kafka队列。
nstance_id}/group { "group_name" : "test" } 响应示例 状态码:200 创建成功。 success SDK代码示例 SDK代码示例如下。 Java Python Go 更多 创建一个消费组,消费组名为test。 1 2 3 4
\"public_ip_address\":\"100.93.2.18\",\"enable_public_ip\":true}", "status" : "SUCCESS", "created_at" : "2020-06-15T08:55:53.606Z", "updated_at" :
ct\",\"origin_retention_policy\":\"time_base\"}", "status" : "SUCCESS", "created_at" : "2020-05-15T03:17:17.176Z", "updated_at" :
在“消费者列表”页签,查看消费者连接地址。 图1 消费者列表 查看消费者连接地址(Kafka Manager) 登录Kafka Manager。 单击“kafka_cluster”,进入集群详情页。 在顶部导航栏单击“Consumers”,进入消费组列表页面。 图2 导航栏 单击待查看消费者连接地址的消费组名称,进入消费组订阅的Topic列表页面。
"data_disk_free" : "63G", "data_disk_use_percentage" : "1", "status" : "Success get info", "topic_list" : [ { "size" : "12K", "topic_name"
results objects 修改实例的结果。 表4 results 参数 参数类型 描述 result String 操作结果。 success: 操作成功 failed: 操作失败 instance String 实例ID。 请求示例 批量重启实例。 POST https:/
方法请参考购买Kafka实例。 区域:华北-北京四 可用区:可用区1 版本:2.7 部署架构:集群 代理规格:kafka.2u4g.cluster 代理数量:3 单代理存储空间:超高I/O,200GB 虚拟私有云:选择虚拟私有云 子网:选择子网 安全组:选择安全组 访问方式:保持默认
户充值。 为用户添加Kafka实例的操作权限。 如果您需要对云上的资源进行精细管理,请使用统一身份认证服务(Identity and Access Management,简称IAM)创建IAM用户及用户组,并授权,以使得IAM用户获得Kafka实例的操作权限。具体操作请参考创建用户并授权使用DMS