NOTE: You are looking at documentation for an older release. For the latest information, see the current release documentation.
Kafka fieldsedit
Kafka module
kafka fieldsedit
broker fieldsedit
Broker 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 fieldsedit
consumergroup
broker fieldsedit
Broker 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 fieldsedit
Assigned 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 fieldsedit
partition
offset fieldsedit
Available 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 fieldsedit
Partition 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