检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
响应Body参数 参数 参数类型 描述 job_id String 修改流控配置的任务ID 请求示例 修改用户/客户端流控配置。 PUT https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
objects 分区信息。 表11 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/ces-hierarchy 响应示例
修改Topic分区的副本分布位置,分区1的副本分布在broker 1和broker 2,Leader副本在broker 1。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
安全 责任共担 身份认证与访问控制 数据保护技术 审计与日志 服务韧性 监控安全风险 认证证书
ring data between clusters。 图1 MirrorMaker原理图 约束与限制 源集群中节点的IP地址和端口号不能和目标集群中节点的IP地址和端口号相同,否则会导致数据在Topic内无限循环复制。 使用MirrorMaker同步数据,至少需要有两个或以上集
参数 参数类型 描述 name String topic名称。 请求示例 创建一个Topic,Topic名称为test01。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "id"
如果已开启公网访问,在“弹性IP地址”中,选择新扩容代理的公网IP地址。 “子网”保持默认设置。 在“内网IP地址”中,选择“自动分配”或者“手动选择”。 自动分配:系统自动分配子网中可用的IP地址。 手动选择:在下拉框中为新扩容代理勾选指定的IP地址。如果指定的IP地址数量少于代理数量时,系统会自动为剩余代理分配IP地址。
请检查安全组规则 400 DMS.00400049 The availability zone does not support ipv6. 可用分区不支持IPv6。 请重新选择可用分区 400 DMS.00400051 not found the new setup version tar
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
"c131886aec...", "name": "IAMUser", "description": "IAM User Description", "areacode": "", "phone": "",
容。 分布式消息服务Kafka版提供了REST(Representational State Transfer)风格API,支持您通过HTTPS请求调用,调用方法请参见如何调用API。 终端节点 终端节点(Endpoint)即调用API的请求地址,不同服务不同区域的终端节点不同,
-1和broker-2上,不同步复制,不同步落盘,消息时间类型为LogAppendTime,最大批处理大小10485760。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "topics"
实例管理 重置密码 重置Manager密码 重启Manager 开启或关闭实例自动创建topic功能 修改实例跨VPC访问的内网IP 查询Kafka集群元数据信息 查询Kafka实例的协调器信息 修改Kafka实例Topic分区的副本 修改Kafka的接入方式 查询topic的磁盘存储情况
String 每个Broker的最大TPS。 product_alias String product_id的别名。 请求示例 GET https://{endpoint}/v2/kafka/products 响应示例 状态码: 200 查询产品规格列表成功。 查询产品规格列表成功。
ms/Kafka服务端节点数”。 修改Kafka客户端的“request.timeout.ms”大于“127s”。 修改Kafka客户端Linux系统的网络参数“net.ipv4.tcp_syn_retries”为“3”。
Topic未设置老化时间时,此参数才对此Topic生效。 1 ~ 168 单位:小时 72 max.connections.per.ip 每个IP允许的最大连接数。超过此连接数的连接请求将被丢弃。 100 ~ 20000 1000 group.max.session.timeout
每个Broker的最大TPS。 product_alias String product_id的别名。 请求示例 查询实例的扩容规格列表。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/extend
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
区。 是否支持Kerberos认证 不支持 客户端单IP连接数 2020年7月以及之后购买的实例,Kafka实例的每个代理允许客户端单IP连接的个数默认为1000个,在此之前购买的实例,Kafka实例的每个代理允许客户端单IP连接的个数默认为200个,如果超过了,会出现连接失败问题。
reassignment_time Integer 预估时间,单位为秒(当执行预估时间任务时仅返回reassignment_time)。 请求示例 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/reassign