检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
该副本当前日志大小。单位：Byte。 lag Long 该副本当前落后hw的消息数。 请求示例 查询指定Topic的详细信息。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/topics/{topic}
图1 设置自动平衡参数 （可选）单击“一键测算”，在“预估耗时”中，显示执行自动平衡大概需要的时间。 一键测算功能对Kafka实例性能没有影响。 单击“确定”。 定时任务和非定时任务查看分区平衡是否完成的方法不同，具体如下： 表2 查看分区平衡结果 任务类型 分区平衡结果 非定时任务
partitions objects 分区信息。 表9 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v1.0/{project_id}/instances/{instance_id}/ceshierarchy
消息内容 property_list Array of objects topic的分区信息等 请求示例 Kafka控制台发送消息 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages/action
topic_partition String 分区。 percentage Double 磁盘使用量的占比。 请求示例 查询Topic的磁盘存储情况 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/diskusage
创建Smart Connect任务 功能介绍 创建Smart Connect任务。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/connector/tasks 表1 路径参数 参数 是否必选
同时，unavailable_zones字段表示资源不足的可用区列表，如果为空，则表示所有可用区都有资源，如果不为空，则表示字段值的可用区没有资源。所以必须确保您购买的资源所在的可用区有资源，不在该字段列表内。 当前页面API为历史版本API，未来可能停止维护。请使用查询产品规格列表。
Kafka客户端使用建议 consumer使用建议 consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 通常不建议对每条消息都进行commit，如果对
修改Topic分区的副本分布位置，分区1的副本分布在broker 1和broker 2，Leader副本在broker 1。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
查询所有实例列表 当前页面API为历史版本API，未来可能停止维护。请使用查询所有实例列表。 功能介绍 查询租户的实例列表，支持按照条件查询。 URI GET /v1.0/{project_id}/instances?engine={engine}&name={name}&sta
-1和broker-2上，不同步复制，不同步落盘，消息时间类型为LogAppendTime，最大批处理大小10485760。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics { "topics"
Connect任务名_source_0”和“Smart Connect任务名_source_1”。 如果Topic中的消息在进行下一次数据同步前，已经全部老化，此时实际是没有待同步的Kafka数据，但是Kafka数据同步监控指标使用的是包含老化数据的offset值，“待同步Kafka数据量”会显示老化的消息数。
面下载Java Development Kit 1.8.111及以上版本。 下载Kafka 3.3.1版本的二进制软件包。 wget https://archive.apache.org/dist/kafka/3.3.1/kafka_2.12-3.3.1.tgz 解压二进制软件包。
reassignment_time Integer 预估时间，单位为秒（当执行预估时间任务时仅返回reassignment_time）。 请求示例 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/reassign
Kafka集群实例 Kafka集群实例规格 Kafka集群实例由三个及以上代理组成，兼容开源Kafka 1.1.0、2.7和3.x。 TPS（Transaction per second），在Kafka场景中，指每秒能写入到Kafka实例的最大消息数量。下表中TPS性能，是指以1
e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId());
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
