kafka Fields

edit

kafka Module beta::[]

kafka Fields

edit

consumergroup Fields

edit

consumergroup

broker Fields

edit

Broker Consumer Group Information have been read from (Broker handling the consumer group).

kafka.consumergroup.broker.id

edit

type: long

Broker id

kafka.consumergroup.broker.address

edit

type: keyword

Broker address

kafka.consumergroup.id

edit

type: keyword

Consumer Group ID

kafka.consumergroup.topic

edit

type: keyword

Topic name

kafka.consumergroup.partition

edit

type: long

Partition ID

kafka.consumergroup.offset

edit

type: long

consumer offset into partition being read

kafka.consumergroup.meta

edit

type: text

custom consumer meta data string

kafka.consumergroup.error.code

edit

type: long

kafka consumer/partition error code.

client Fields

edit

Assigned client reading events from partition

kafka.consumergroup.client.id

edit

type: keyword

Client ID (kafka setting client.id)

kafka.consumergroup.client.host

edit

type: keyword

Client host

kafka.consumergroup.client.member_id

edit

type: keyword

internal consumer group member ID

partition Fields

edit

partition

offset Fields

edit

Available offsets of the given partition.

kafka.partition.offset.newest

edit

type: long

Newest offset of the partition.

kafka.partition.offset.oldest

edit

type: long

Oldest offset of the partition.

partition Fields

edit

Partition data.

kafka.partition.partition.id

edit

type: long

Partition id.

kafka.partition.partition.leader

edit

type: long

Leader id (broker).

kafka.partition.partition.isr

edit

type: list

List of isr ids.

kafka.partition.partition.replica

edit

type: long

Replica id (broker).

kafka.partition.partition.insync_replica

edit

type: boolean

Indicates if replica is included in the in-sync replicate set (ISR).

kafka.partition.partition.error.code

edit

type: long

Error code from fetching partition.

kafka.partition.topic.error.code

edit

type: long

topic error code.

kafka.partition.topic.name

edit

type: keyword

Topic name

kafka.partition.broker.id

edit

type: long

Broker id

kafka.partition.broker.address

edit

type: keyword

Broker address