kafka Fieldsedit

kafka Module [beta] This functionality is in beta and is subject to change. The design and code is considered to be less mature than official GA features. Elastic will take a best effort approach to fix any issues, but beta features are not subject to the support SLA of official GA features.

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

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