Kafka fieldsedit

Kafka module

kafka fieldsedit

consumergroup fieldsedit

consumergroup

broker fieldsedit

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

kafka.consumergroup.broker.idedit

type: long

Broker id

kafka.consumergroup.broker.addressedit

type: keyword

Broker address

kafka.consumergroup.idedit

type: keyword

Consumer Group ID

kafka.consumergroup.topicedit

type: keyword

Topic name

kafka.consumergroup.partitionedit

type: long

Partition ID

kafka.consumergroup.offsetedit

type: long

consumer offset into partition being read

kafka.consumergroup.metaedit

type: text

custom consumer meta data string

kafka.consumergroup.error.codeedit

type: long

kafka consumer/partition error code.

client fieldsedit

Assigned client reading events from partition

kafka.consumergroup.client.idedit

type: keyword

Client ID (kafka setting client.id)

kafka.consumergroup.client.hostedit

type: keyword

Client host

kafka.consumergroup.client.member_idedit

type: keyword

internal consumer group member ID

partition fieldsedit

partition

offset fieldsedit

Available offsets of the given partition.

kafka.partition.offset.newestedit

type: long

Newest offset of the partition.

kafka.partition.offset.oldestedit

type: long

Oldest offset of the partition.

partition fieldsedit

Partition data.

kafka.partition.partition.idedit

type: long

Partition id.

kafka.partition.partition.leaderedit

type: long

Leader id (broker).

kafka.partition.partition.isredit

type: array

List of isr ids.

kafka.partition.partition.replicaedit

type: long

Replica id (broker).

kafka.partition.partition.insync_replicaedit

type: boolean

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

kafka.partition.partition.error.codeedit

type: long

Error code from fetching partition.

kafka.partition.topic.error.codeedit

type: long

topic error code.

kafka.partition.topic.nameedit

type: keyword

Topic name

kafka.partition.broker.idedit

type: long

Broker id

kafka.partition.broker.addressedit

type: keyword

Broker address