WARNING: Version 6.0 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 beta::[]
kafka Fieldsedit
consumergroup Fieldsedit
consumergroup
broker Fieldsedit
Broker Consumer Group Information have been read from (Broker handling the consumer group).
kafka.consumergroup.broker.idedit
type: long
Broker id
kafka.consumergroup.broker.addressedit
type: keyword
Broker address
kafka.consumergroup.idedit
type: keyword
Consumer Group ID
kafka.consumergroup.topicedit
type: keyword
Topic name
kafka.consumergroup.partitionedit
type: long
Partition ID
kafka.consumergroup.offsetedit
type: long
consumer offset into partition being read
kafka.consumergroup.metaedit
type: text
custom consumer meta data string
kafka.consumergroup.error.codeedit
type: long
kafka consumer/partition error code.
client Fieldsedit
Assigned client reading events from partition
kafka.consumergroup.client.idedit
type: keyword
Client ID (kafka setting client.id)
kafka.consumergroup.client.hostedit
type: keyword
Client host
kafka.consumergroup.client.member_idedit
type: keyword
internal consumer group member ID
partition Fieldsedit
partition
offset Fieldsedit
Available offsets of the given partition.
kafka.partition.offset.newestedit
type: long
Newest offset of the partition.
kafka.partition.offset.oldestedit
type: long
Oldest offset of the partition.
partition Fieldsedit
Partition data.
kafka.partition.partition.idedit
type: long
Partition id.
kafka.partition.partition.leaderedit
type: long
Leader id (broker).
kafka.partition.partition.isredit
type: array
List of isr ids.
kafka.partition.partition.replicaedit
type: long
Replica id (broker).
kafka.partition.partition.insync_replicaedit
type: boolean
Indicates if replica is included in the in-sync replicate set (ISR).
kafka.partition.partition.error.codeedit
type: long
Error code from fetching partition.
kafka.partition.topic.error.codeedit
type: long
topic error code.
kafka.partition.topic.nameedit
type: keyword
Topic name
kafka.partition.broker.idedit
type: long
Broker id
kafka.partition.broker.addressedit
type: keyword
Broker address