WARNING: Version 5.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 Fields
editkafka Fields
editkafka Module experimental::[]
kafka Fields
editconsumergroup Fields
editconsumergroup
broker Fields
editBroker Consumer Group Information have been read from (Broker handling the consumer group).
kafka.consumergroup.broker.id
edittype: long
Broker id
kafka.consumergroup.broker.address
edittype: keyword
Broker address
kafka.consumergroup.id
edittype: keyword
Consumer Group ID
kafka.consumergroup.topic
edittype: keyword
Topic name
kafka.consumergroup.partition
edittype: long
Partition ID
kafka.consumergroup.offset
edittype: long
consumer offset into partition being read
kafka.consumergroup.meta
edittype: text
custom consumer meta data string
kafka.consumergroup.error.code
edittype: long
kafka consumer/partition error code.
client Fields
editAssigned client reading events from partition
kafka.consumergroup.client.id
edittype: keyword
Client ID (kafka setting client.id)
kafka.consumergroup.client.host
edittype: keyword
Client host
kafka.consumergroup.client.member_id
edittype: keyword
internal consumer group member ID
partition Fields
editpartition
offset Fields
editAvailable offsets of the given partition.
kafka.partition.offset.newest
edittype: long
Newest offset of the partition.
kafka.partition.offset.oldest
edittype: long
Oldest offset of the partition.
partition Fields
editPartition data.
kafka.partition.partition.id
edittype: long
Partition id.
kafka.partition.partition.leader
edittype: long
Leader id (broker).
kafka.partition.partition.isr
edittype: list
List of isr ids.
kafka.partition.partition.replica
edittype: long
Replica id (broker).
kafka.partition.partition.insync_replica
edittype: boolean
Indicates if replica is included in the in-sync replicate set (ISR).
kafka.partition.partition.error.code
edittype: long
Error code from fetching partition.
kafka.partition.topic.error.code
edittype: long
topic error code.
kafka.partition.topic.name
edittype: keyword
Topic name
kafka.partition.broker.id
edittype: long
Broker id
kafka.partition.broker.address
edittype: keyword
Broker address