Kafka 字段

Kafka 模块

kafka

broker

从以下位置读取代理消费者组信息(处理消费者组的代理)。

kafka.broker.id

代理 ID

类型:long

kafka.broker.address

代理公告地址

类型:keyword

kafka.topic.name

主题名称

类型:keyword

kafka.topic.error.code

主题错误代码。

类型:long

kafka.partition.id

分区 ID。

类型:long

kafka.partition.topic_id

主题中分区的唯一 ID。

类型:keyword

kafka.partition.topic_broker_id

主题和代理中分区的唯一 ID。

类型:keyword

broker

来自 Kafka 代理 JMX 的代理指标

kafka.broker.mbean

此事件相关的 MBean

类型:keyword

kafka.broker.request.channel.queue.size

请求队列的大小

类型:long

kafka.broker.request.produce.failed_per_second

每秒失败的生产请求率

类型:float

kafka.broker.request.fetch.failed_per_second

每秒客户端获取请求失败率

类型:float

kafka.broker.request.produce.failed

失败的生产请求数

类型:float

kafka.broker.request.fetch.failed

客户端获取请求失败数

类型:float

kafka.broker.replication.leader_elections

领导者选举率

类型:float

kafka.broker.replication.unclean_leader_elections

不干净的领导者选举率

类型:float

kafka.broker.session.zookeeper.disconnect

每秒 ZooKeeper 关闭的会话数

类型:float

kafka.broker.session.zookeeper.expire

每秒 ZooKeeper 过期的会话数

类型:float

kafka.broker.session.zookeeper.readonly

每秒 ZooKeeper 只读会话数

类型:float

kafka.broker.session.zookeeper.sync

每秒 ZooKeeper 客户端连接数

类型:float

kafka.broker.log.flush_rate

日志刷新率

类型:float

kafka.broker.topic.net.in.bytes_per_sec

每个主题的传入字节率

类型:float

kafka.broker.topic.net.out.bytes_per_sec

每个主题的传出字节率

类型:float

kafka.broker.topic.net.rejected.bytes_per_sec

每个主题的拒绝字节率

类型:float

kafka.broker.topic.messages_in

每个主题的传入消息率

类型:float

kafka.broker.net.in.bytes_per_sec

传入字节率

类型:float

kafka.broker.net.out.bytes_per_sec

传出字节率

类型:float

kafka.broker.net.rejected.bytes_per_sec

拒绝字节率

类型:float

kafka.broker.messages_in

传入消息率

类型:float

consumer

来自 Kafka 消费者 JMX 的消费者指标

kafka.consumer.mbean

此事件相关的 MBean

类型:keyword

kafka.consumer.fetch_rate

消费者向代理发送获取请求的最低速率

类型:float

kafka.consumer.bytes_consumed

特定主题每秒平均消费的字节数

类型:float

kafka.consumer.records_consumed

特定主题每秒平均消费的记录数

类型:float

kafka.consumer.in.bytes_per_sec

进入消费者的字节速率

类型:float

kafka.consumer.max_lag

最大消费者延迟

类型:float

kafka.consumer.zookeeper_commits

向 ZooKeeper 提交偏移量的速率

类型:float

kafka.consumer.kafka_commits

向 Kafka 提交偏移量的速率

类型:float

kafka.consumer.messages_in

消费者消息消费率

类型:float

consumergroup

consumergroup

kafka.consumergroup.id

消费者组 ID

类型:keyword

kafka.consumergroup.offset

正在读取的分区中的消费者偏移量

类型:long

kafka.consumergroup.meta

自定义消费者元数据字符串

类型:keyword

kafka.consumergroup.consumer_lag

分区/主题的消费者延迟,计算为分区偏移量和消费者偏移量之间的差值

类型:long

kafka.consumergroup.error.code

kafka 消费者/分区错误代码。

类型:long

client

分配的客户端从分区读取事件

kafka.consumergroup.client.id

客户端 ID(kafka 设置 client.id)

类型:keyword

kafka.consumergroup.client.host

客户端主机

类型:keyword

kafka.consumergroup.client.member_id

内部消费者组成员 ID

类型:keyword

partition

partition

offset

给定分区的可用偏移量。

kafka.partition.offset.newest

分区的最新偏移量。

类型:long

kafka.partition.offset.oldest

分区的最旧偏移量。

类型:long

partition

分区数据。

kafka.partition.partition.leader

领导者 ID(代理)。

类型:long

kafka.partition.partition.replica

副本 ID(代理)。

类型:long

kafka.partition.partition.insync_replica

指示副本是否包含在同步副本集中 (ISR)。

类型:boolean

kafka.partition.partition.is_leader

指示副本是否是领导者

类型:boolean

kafka.partition.partition.error.code

从获取分区获取的错误代码。

类型:long

producer

来自 Kafka 生产者 JMX 的生产者指标

kafka.producer.mbean

此事件相关的 MBean

类型:keyword

kafka.producer.available_buffer_bytes

缓冲内存的总量

类型:float

kafka.producer.batch_size_avg

发送的平均字节数

类型:float

kafka.producer.batch_size_max

发送的最大字节数

类型:long

kafka.producer.record_send_rate

每秒发送的平均记录数

类型:float

kafka.producer.record_retry_rate

每秒平均重试发送的记录数

类型:float

kafka.producer.record_error_rate

每秒平均重试发送的记录数

类型:float

kafka.producer.records_per_request

每秒发送的平均记录数

类型:float

kafka.producer.record_size_avg

平均记录大小

类型:float

kafka.producer.record_size_max

最大记录大小

类型:long

kafka.producer.request_rate

每秒的生产者请求数

类型:float

kafka.producer.response_rate

每秒的生产者响应数

类型:float

kafka.producer.io_wait

生产者 I/O 等待时间

类型:float

kafka.producer.out.bytes_per_sec

生产者传出字节速率

类型:float

kafka.producer.message_rate

生产者消息速率

类型:float