检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消息。 batch.size：每次批量发送消息的大小（单位为字节）。 linger.ms：两次发送时间间隔。 topic：创建Topic中设置的Topic名称。 num-records：总共需要发送的消息数。 record-size：每条消息的大小。 throughput：每秒发送的消息数。
如果您持有多台到期日不同的Kafka实例，可以将到期日统一设置到一个日期，便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源，同时续费一个月，并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。 父主题： 续费
消息。 batch.size：每次批量发送消息的大小（单位为字节）。 linger.ms：两次发送时间间隔。 topic：创建Topic中设置的Topic名称。 num-records：总共需要发送的消息数。 record-size：每条消息的大小。 throughput：每秒发送的消息数。
coordinator_id Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups
实例ID。 task_id 是 String 任务ID。 请求参数 无 响应参数 无 请求示例 删除后台任务管理中的指定记录。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/tasks/{task_id}
String 实例ID。 task_id 是 String Smart Connect任务ID。 请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause
String 实例ID。 task_id 是 String Smart Connect任务ID。 请求参数 无 响应参数 无 请求示例 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume
TagMultyValueEntity 参数 参数类型 描述 key String 标签键。 values Array of strings 标签值。 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码：200 查询项目标签成功。 { "tags"
是否使用用户默认设置。 是，表示对全部用户限流。此时不能同时设置用户名。 否，表示对特定用户限流。此时需要设置用户名。 client-default Boolean 是否使用客户端默认设置。 是，表示对全部客户端限流。此时不能设置客户端ID。 否，表示对特定客户端限流。此时需要设置客户端ID。
参数类型 描述 sink_max_tasks 是 Integer 转储任务的总个数。 响应参数 无 请求示例 修改转储任务的配额。 PUT https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks {
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例id 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/management
实例ID。 task_id 是 String Smart Connector任务ID。 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 无 请求示例 删除指定的实例。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id} 响应示例 无 SDK代码示例
在告警规则页面，设置告警信息。 创建告警规则操作，请查看创建告警规则。 设置告警名称和告警的描述。 设置告警策略。 如下图所示，在进行指标监控时，如果连续1次，磁盘容量使用率原始值>=80%，则产生告警，如果未及时处理，则产生告警通知。 图1 设置告警策略 设置“发送通知”开关。
步骤三：添加DNAT规则 在“公网NAT网关”页面，在新购买的公网NAT网关后，单击“设置规则”，进入公网NAT网关详情页。 在“DNAT规则”页签，单击“添加DNAT规则”，弹出“添加DNAT规则”对话框。 图3 公网NAT网关详情页 设置如下参数。 使用场景：选择“虚拟私有云” 端口类型：选择“具体端口”
使用MirrorMaker跨集群同步数据 使用MirrorMaker可以实现将源集群中的数据镜像复制到目标集群中。 配置消息堆积数监控 介绍如何设置消息组的消息堆积数超过阈值时，消息通知服务及时发送告警短信/邮件通知用户。
message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置（LEO）。 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}
Kafka单机实例Topic数量计算 Kafka实例对Topic分区数之和设置了上限，当达到上限之后，用户无法继续创建Topic。 所以，Topic数量和实例分区数上限、每个Topic的分区数有关，其中，每个Topic分区数可在创建Topic时设置，实例分区数上限参考表1。 kafka.2u4g.single实例的分区数上限为250。
消费者的消费能力不足（消费者并发低、消息处理时间长），导致消费效率低于生产效率。 消费者异常（如消费者故障、消费者网络异常等）导致无法消费消息。 Topic分区设置不合理，或新增分区无消费者消费。 Topic频繁重平衡导致消费效率降低。 实施步骤 从消息堆积的原因看，消息堆积问题可以从消费者端、生产者端和服务端三个方面进行处理。
String 转储任务状态。 topics String 返回任务转存的topics列表或者正则表达式。 请求示例 查询转储任务列表。 GET https://{endpoint}/v2/{project_id}/connectors/{connector_id}/sink-tasks 响应示例
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
