统计值，“latest”表示从上次重置到当前时间的统计值。 P99时延的计算是近似值，不提供精确值，越靠近两端的统计值越准确，即99%的时延比50%的时延更准确。 如果重启集群，P99时延数据将被清空，P99时延数据将从集群重启成功后重新计算。 其他操作 自定义百分百数值。 您可以自行指定百分百数值：

查看更多 →

消息从生产到消费时延高达6分钟 问题现象 消息从生产到消费的端到端时延偶现到达6分钟，业务对消息时延较为敏感。 分析过程 怀疑是业务堆积，处理慢导致时延。 通过查看监控数据，发现业务请求并不是很多，堆积最多时也只有50条消息，同时每秒新增消息只有10条左右，应该还没有到达处理极限。

查看更多 →

查看Kafka监控数据 云监控对Kafka实例的运行状态进行日常监控，可以通过控制台直观的查看Kafka实例各项监控指标。 前提条件 已创建Kafka实例，且实例中有可消费的消息。 查看Kafka监控数据 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。

查看更多 →

云监控无法展示Kafka监控数据 Topic监控数据无法展示，可能原因如下： Topic名称开头包含特殊字符，例如#号“#”。 Kafka实例中没有创建Topic。 解决方法如下： 删除带特殊字符的Topic。 创建Topic。 消费组监控数据无法展示，可能原因如下： 消费组名称开头包含特殊字符，例如#号“#”。

查看更多 →

> 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 通过以下任意一种方法，进入监控页面。 在Kafka实例名称后，单击“查看监控数据”，进入云监控该实例的监控指标页面。 单击Kafka实例名称，进入实例详情页。在左侧导航栏单击“监控与告警 > 监控详情”，进入监控页面。

查看更多 →

计费时长指的是？ 计费时长一般指的是用户购买集群开始后的时长。 父主题： 计费类

查看更多 →

Kafka集群监控管理 Kafka集群监控管理包含以下内容： 查看Broker信息 查看Topic信息 查看Consumers信息 通过KafkaManager修改Topic的partition 查看Broker信息 登录KafkaManager的WebUI界面。 在集群列表页面

查看更多 →

单位：Count ≥ 0 Kafka实例的Smart Connect任务 1分钟 task_status 任务状态 当前任务状态。 0：任务异常 1：任务正常 Kafka实例的Smart Connect任务 1分钟 message_delay 消息时延 消息到达源端的时间与到达目标端的时间之差。

查看更多 →

maxTime 最慢时延 最慢时延 - INT MAX range1 0–10ms 时延在0-10ms范围调用次数 - INT SUM range2 10–100ms 时延在10–100ms范围调用次数 - INT SUM range3 100–500ms 时延在100–500ms范围调用次数

查看更多 →

续费时，可选择的续费时长有哪些？ 为产品手动操作续费、设置自动续费时，可选择的续费时长有：1个月、2个月、3个月、4个月、5个月、6个月、7个月、8个月、9个月、1年、2年和3年等（具体可选择的续费时长以续费操作页面显示为准）。 父主题： 续费

查看更多 →

fetch (fetch，kafka的fetch监控数据) id id clientid和ip信息 - ENUM LAST bytesConsumedRate 每秒消费字节 每秒消费字节 Byte INT AVG fetchLatencyAvg 请求平均时延 请求平均时延 ms INT AVG

查看更多 →

先购买Kafka实例。Kafka实例采用物理隔离的方式部署，租户独占Kafka实例。 支持区域： 全部 购买Kafka实例 连接Kafka 开源Kafka客户端向Kafka实例生产消息和消费消息前，需要先连接Kafka实例。 创建Kafka实例时，支持开启或者关闭SASL_SSL

查看更多 →

5则为HIGH。 时延 Source端会周期性地发送带当前时间戳的LatencyMarker，下游算子接收到该标记后，通过当前时间减去标记中带的时间戳的方式，计算时延指标。算子的反压状态和时延可以通过Flink UI或者作业任务列表查看，一般情况下反压和高时延成对出现： 图2 反压状态和时延

查看更多 →

华为云 分布式消息服务Kafka版 分布式消息服务Kafka版（Distributed Message Service for Kafka）是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。 免费体验 图说Kafka 立即使用

查看更多 →

地间的低时延、高质量的网络互通。（该线路资源仅在“中国-香港”区域支持。） 边缘线路：计费模式为按需计费时，该项可见。边缘线路是通过靠近用户和终端的网络边缘站点，实现区域内低时延高带宽的网络服务。边缘小站详细信息请参见 智能边缘小站。 公网IP池：计费模式为按需计费时，该项可见。

查看更多 →

修改消费时间点 数据复制服务支持在消费的过程中，随时修改消费时间点，修改的时间点必须在订阅任务的时间范围内。一旦修改完消费时间点，那么下游SDK拉取到的增量数据从修改后的消费时间点开始。 本章节将详细介绍通过数据复制服务管理控制台修改消费时间点的操作步骤。 约束限制 数据订阅任务已启动且任务为“正常”状态。

查看更多 →

费组的监控数据。 producer使用建议 同步复制客户端需要配合使用：acks=all 配置发送失败重试：retries=3 发送优化：对于时延敏感的信息，设置linger.ms=0。对于时延不敏感的信息，设置linger.ms在100~1000之间。 生产端的JVM内存要足够，避免内存不足导致发送阻塞。

查看更多 →

Kafka Kafka是一个分布式流处理平台，最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理服务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是

查看更多 →

续费时，可变更云服务配置吗？ 不可以。如果客户想变更云服务配置，可在续费前或者续费后操作。 若先变更规格后续费，续费周期可以单独退订；若先续费，后变更规格，则续费周期不能退订。 父主题： 续费

查看更多 →

Kafka Kafka jar包冲突列表 Jar包名称 描述 kafka_2.11-*.jar 连接Kafka服务必须的jar包。 kafka-clients-*.jar 连接Kafka服务必须的jar包。 解决方案 Kafka不建议使用开源版本的包。 父主题： MRS 应用开发开源jar包冲突列表说明

查看更多 →

Broker的时间。 消息键（Key）与消息体（Value）的格式 Kafka消息的消息键和消息体部分都可以使用某种格式来序列化或反序列化成二进制数据。 消息体格式 由于 Kafka 消息中消息键是可选的，以下语句将使用消息体格式读取和写入消息，但不使用消息键格式。 'format'

查看更多 →