18.5. 重要的 Kafka 代理指标

每秒的消息

kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec

代理消耗单个消息的速度。

与集群中的其他代理相同。

每秒的字节数

kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec

从制作者发送的数据的速率由代理消耗。

与集群中的其他代理相同。

每秒复制字节数

kafka.server:type=BrokerTopicMetrics,name=ReplicationBytesInPerSec

从其他代理发送的数据的速度由后续代理消耗。

N/A

每秒的字节数

kafka.server:type=BrokerTopicMetrics,name=BytesOutPerSec

被消费者获取并从代理中读取数据的速度。

N/A

每秒复制字节数

kafka.server:type=BrokerTopicMetrics,name=ReplicationBytesOutPerSec

从代理发送到其他代理的数据的速度。这个指标可用于监控代理是一组分区的领导功能。

N/A

底层分区

kafka.server:type=ReplicaManager,name=UnderReplicatedPartitions

以下副本中未完全复制的分区数量。

Zero

至少 ISR 分区数

kafka.server:type=ReplicaManager,name=UnderMinIsrPartitionCount

最少 In-Sync Replica(ISR)计数中的分区数量。ISR 计数表示一组与领导有关的副本数。

Zero

分区数

kafka.server:type=ReplicaManager,name=PartitionCount

代理中的分区数量。

大约在与其他代理进行比较时也是如此。

领导计数

kafka.server:type=ReplicaManager,name=LeaderCount

此代理是领导的副本数。

与集群中的其他代理相同。

ISR 每秒缩小

kafka.server:type=ReplicaManager,name=IsrShrinksPerSec

代理中 ISRs 数量的频率

Zero

ISR 每秒扩展

kafka.server:type=ReplicaManager,name=IsrExpandsPerSec

代理中 ISRs 数会增加的速率。

Zero

最大 lag

kafka.server:type=ReplicaFetcherManager,name=MaxLag,clientId=Replica

在领导副本接收消息由领导副本和后续副本接收的时间之间的最大滞后。

比例与生成请求的最大批处理大小成比例。

以生产者购买的请求

kafka.server:type=DelayedOperationPurgatory,name=PurgatorySize,delayedOperation=Produce

在制作者购买中发送请求数。

N/A

获取购买请求

kafka.server:type=DelayedOperationPurgatory,name=PurgatorySize,delayedOperation=Fetch

获取获取获取请求的数量。

N/A

请求处理器的平均空闲百分比

kafka.server:type=KafkaRequestHandlerPool,name=RequestHandlerAvgIdlePercent

指明请求处理器(IO)线程不在使用的百分比。

较低值表示代理的工作负载非常高。

请求（请求来自节流）

kafka.server:type=Request

从节流中活跃的请求数。

N/A

zookeeper 请求延迟（以毫秒为单位）

kafka.server:type=ZooKeeperClientMetrics,name=ZooKeeperRequestLatencyMs

来自代理的 ZooKeeper 请求的延迟，以毫秒为单位。

N/A

zookeeper 会话状态

kafka.server:type=SessionExpireListener,name=SessionState

代理与 ZooKeeper 的连接状态。

已连接

每秒请求数

Kafka.network:type=RequestMetrics,name=RequestsPerSec,request={Produce|FetchConsumer|FetchFollower}

每秒为请求类型的请求总数。Produce、FetchConsumer 和 FetchFollower 请求类型各自都有自己的 MBeans。

N/A

请求字节（请求大小（以字节为单位）

kafka.network:type=RequestMetrics,name=RequestBytes,request=([-.\w]+)

请求数（以字节为单位）由 MBean 名称的 request 属性标识。所有可用的请求类型的单独的 MBeans 列在 RequestBytes 节点下。

N/A

临时内存大小（以字节为单位）

kafka.network:type=RequestMetrics,name=TemporaryMemoryBytes,request={Produce|Fetch}

用于转换消息格式和解压缩消息的临时内存量。

N/A

消息转换时间

kafka.network:type=RequestMetrics,name=MessageConversionsTimeMs,request={Produce|Fetch}

转换消息格式的时间（以毫秒为单位）。

N/A

请求总数（以毫秒为单位）

Kafka.network:type=RequestMetrics,name=TotalTimeMs,request={Produce|FetchConsumer|FetchFollower}

处理请求的总时间（以毫秒为单位）。

N/A

请求队列时间（以毫秒为单位）

Kafka.network:type=RequestMetrics,name=RequestQueueTimeMs,request={Produce|FetchConsumer|FetchFollower}

请求当前在 request 属性中给定的请求类型的时间（以毫秒为单位）。

N/A

本地时间（领导本地处理时间）以毫秒为单位

Kafka.network:type=RequestMetrics,name=LocalTimeMs,request={Produce|FetchConsumer|FetchFollower}

处理请求的时间（以毫秒为单位）。

N/A

远程时间（领导远程处理时间）以毫秒为单位

Kafka.network:type=RequestMetrics,name=RemoteTimeMs,request={Produce|FetchConsumer|FetchFollower}

请求等待后续时间长度（以毫秒为单位）。RemoteTimeMs 节点列出了单独的 MBeans 用于所有可用请求类型。

N/A

以毫秒为单位响应队列时间

Kafka.network:type=RequestMetrics,name=ResponseQueueTimeMs,request={Produce|FetchConsumer|FetchFollower}

请求在响应队列中等待的时间长度（以毫秒为单位）。

N/A

响应时间（以毫秒为单位）

Kafka.network:type=RequestMetrics,name=ResponseSendTimeMs,request={Produce|FetchConsumer|FetchFollower}

发送响应的时间（以毫秒为单位）。

N/A

网络处理器平均空闲百分比

kafka.network:type=SocketServer,name=NetworkProcessorAvgIdlePercent

网络处理器闲置的平均时间百分比。

在零到一。

日志冲刷率和时间（以毫秒为单位）

kafka.log:type=LogFlushStats,name=LogFlushRateAndTimeMs

日志数据写入磁盘的速度（以毫秒为单位）。

N/A

离线日志目录计数

kafka.log:type=LogManager,name=OfflineLogDirectoryCount

离线日志目录的数量（例如，在硬件故障后）。

Zero

活跃控制器计数

kafka.controller:type=KafkaController,name=ActiveControllerCount

指定为控制器的代理数量。

一个表示代理是集群的控制器。

以毫秒为单位的领导选举率和时间

kafka.controller:type=ControllerStats,name=LeaderElectionRateAndTimeMs

选择新领导副本的速率。

Zero