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

在后续副本中未完全复制的分区数量。

零

最小 ISR 分区计数

kafka.server:type=ReplicaManager,name=UnderMinIsrPartitionCount

最小 In-Sync Replica (ISR)计数下的分区数量。ISR 计数表示与领导最新的一组副本。

零

分区计数

kafka.server:type=ReplicaManager,name=PartitionCount

代理中的分区数量。

甚至在与其他代理相比也是如此。

领导数

kafka.server:type=ReplicaManager,name=LeaderCount

此代理是领导的副本数。

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

ISR 会每秒缩小

kafka.server:type=ReplicaManager,name=IsrShrinksPerSec

代理中 ISR 数量减少的速度

零

ISR 会每秒扩展

kafka.server:type=ReplicaManager,name=IsrExpandsPerSec

代理中的 ISR 数量增加的频率。

零

最大滞后

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

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

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

requests in producer purgatory

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

制作者中发送请求的数量。

N/A

获取 purgatory 的请求

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

获取中的获取请求数。

N/A

请求处理程序平均空闲百分比

kafka.server:type=KafkaRequestHandlerPool,name=RequestHandlerAvgIdlePercent

表示请求处理程序(IO)线程没有使用的时间百分比。

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

Request (Requests exempt fromthrottle)

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 属性标识的请求类型（以字节为单位）。RequestBytes 节点下列出了用于所有可用请求类型的单独 MBeans。

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}

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

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

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

零

活跃控制器计数

kafka.controller:type=KafkaController,name=ActiveControllerCount

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

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

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

kafka.controller:type=ControllerStats,name=LeaderElectionRateAndTimeMs

选择新领导副本的频率。

零