WARNING: Version 6.2 of Metricbeat has passed its EOL date.
This documentation is no longer being maintained and may be removed. If you are running this version, we strongly advise you to upgrade. For the latest information, see the current release documentation.
Kafka fieldsedit
Kafka module
kafka fieldsedit
consumergroup fieldsedit
consumergroup
broker fieldsedit
Broker Consumer Group Information have been read from (Broker handling the consumer group).
kafka.consumergroup.broker.id
edit
type: long
Broker id
kafka.consumergroup.broker.address
edit
type: keyword
Broker address
kafka.consumergroup.id
edit
type: keyword
Consumer Group ID
kafka.consumergroup.topic
edit
type: keyword
Topic name
kafka.consumergroup.partition
edit
type: long
Partition ID
kafka.consumergroup.offset
edit
type: long
consumer offset into partition being read
kafka.consumergroup.meta
edit
type: text
custom consumer meta data string
kafka.consumergroup.error.code
edit
type: long
kafka consumer/partition error code.
client fieldsedit
Assigned client reading events from partition
kafka.consumergroup.client.id
edit
type: keyword
Client ID (kafka setting client.id)
kafka.consumergroup.client.host
edit
type: keyword
Client host
kafka.consumergroup.client.member_id
edit
type: keyword
internal consumer group member ID
partition fieldsedit
partition
offset fieldsedit
Available offsets of the given partition.
kafka.partition.offset.newest
edit
type: long
Newest offset of the partition.
kafka.partition.offset.oldest
edit
type: long
Oldest offset of the partition.
partition fieldsedit
Partition data.
kafka.partition.partition.id
edit
type: long
Partition id.
kafka.partition.partition.leader
edit
type: long
Leader id (broker).
kafka.partition.partition.isr
edit
type: array
List of isr ids.
kafka.partition.partition.replica
edit
type: long
Replica id (broker).
kafka.partition.partition.insync_replica
edit
type: boolean
Indicates if replica is included in the in-sync replicate set (ISR).
kafka.partition.partition.error.code
edit
type: long
Error code from fetching partition.
kafka.partition.topic.error.code
edit
type: long
topic error code.
kafka.partition.topic.name
edit
type: keyword
Topic name
kafka.partition.broker.id
edit
type: long
Broker id
kafka.partition.broker.address
edit
type: keyword
Broker address