kafka Module [experimental] This functionality is experimental and may be changed or removed completely in a future release.

kafka Fieldsedit

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