Kafka fields

edit

Kafka module

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: array

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