Kafka fields

Kafka module

kafka fields

consumergroup fields

consumergroup

broker fields

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

type: keyword

Topic name

kafka.consumergroup.partition

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

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 fields

partition

offset fields

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 fields

Partition data.

kafka.partition.partition.id

type: long

Partition id.

kafka.partition.partition.leader

type: long

Leader id (broker).

kafka.partition.partition.isr

type: array

List of isr ids.

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.error.code

type: long

Error code from fetching partition.

kafka.partition.topic.error.code

type: long

topic error code.

kafka.partition.topic.name

type: keyword

Topic name

kafka.partition.broker.id

type: long

Broker id

kafka.partition.broker.address

type: keyword

Broker address