NOTE: You are looking at documentation for an older release. For the latest information, see the current release documentation.
Kafka fields
editKafka fields
editKafka module
kafka fields
editbroker fields
editBroker Consumer Group Information have been read from (Broker handling the consumer group).
-
kafka.broker.id
-
type: long
Broker id
-
kafka.broker.address
-
type: keyword
Broker advertised address
-
kafka.topic.name
-
type: keyword
Topic name
-
kafka.topic.error.code
-
type: long
Topic error code.
-
kafka.partition.id
-
type: long
Partition id.
-
kafka.partition.topic_id
-
type: keyword
Unique id of the partition in the topic.
-
kafka.partition.topic_broker_id
-
type: keyword
Unique id of the partition in the topic and the broker.
consumergroup fields
editconsumergroup
broker fields
editBroker Consumer Group Information have been read from (Broker handling the consumer group).
-
kafka.consumergroup.broker.id
-
type: long
Broker id
-
kafka.consumergroup.broker.address
-
type: keyword
Broker address
-
kafka.consumergroup.id
-
type: keyword
Consumer Group ID
-
kafka.consumergroup.topic
-
[6.5] Deprecated in 6.5.
type: keyword
Topic name
-
kafka.consumergroup.partition
-
[6.5] Deprecated in 6.5.
type: long
Partition ID
-
kafka.consumergroup.offset
-
type: long
consumer offset into partition being read
-
kafka.consumergroup.meta
-
type: text
custom consumer meta data string
-
kafka.consumergroup.error.code
-
type: long
kafka consumer/partition error code.
client fields
editAssigned client reading events from partition
-
kafka.consumergroup.client.id
-
type: keyword
Client ID (kafka setting client.id)
-
kafka.consumergroup.client.host
-
type: keyword
Client host
-
kafka.consumergroup.client.member_id
-
type: keyword
internal consumer group member ID
partition fields
editpartition
offset fields
editAvailable offsets of the given partition.
-
kafka.partition.offset.newest
-
type: long
Newest offset of the partition.
-
kafka.partition.offset.oldest
-
type: long
Oldest offset of the partition.
partition fields
editPartition data.
-
kafka.partition.partition.id
-
[6.5] Deprecated in 6.5.
type: long
Partition id.
-
kafka.partition.partition.leader
-
type: long
Leader id (broker).
-
kafka.partition.partition.replica
-
type: long
Replica id (broker).
-
kafka.partition.partition.insync_replica
-
type: boolean
Indicates if replica is included in the in-sync replicate set (ISR).
-
kafka.partition.partition.is_leader
-
type: boolean
Indicates if replica is the leader
-
kafka.partition.partition.error.code
-
type: long
Error code from fetching partition.
-
kafka.partition.topic.error.code
-
[6.5] Deprecated in 6.5.
type: long
topic error code.
-
kafka.partition.topic.name
-
[6.5] Deprecated in 6.5.
type: keyword
Topic name
-
kafka.partition.broker.id
-
[6.5] Deprecated in 6.5.
type: long
Broker id
-
kafka.partition.broker.address
-
[6.5] Deprecated in 6.5.
type: keyword
Broker address