kafka Fields

kafka Module experimental::[]

kafka Fields

partition Fields

partition

offset Fields

Available offsets of the given partition.

kafka.partition.offset.newest

type: long

Newest offset of the partition.

kafka.partition.offset.oldest

type: long

Oldest offset of the partition.

partition Fields

Partition data.

kafka.partition.partition.id

type: long

Partition id.

kafka.partition.partition.leader

type: long

Leader id (broker).

kafka.partition.partition.isr

type: list

List of isr ids.

kafka.partition.partition.replica

type: long

Replica id (broker).

kafka.partition.partition.insync_replica

type: boolean

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

kafka.partition.partition.error.code

type: long

Error code from fetching partition.

kafka.partition.topic.error.code

type: long

topic error code.

kafka.partition.topic.name

type: keyword

Topic name

kafka.partition.broker.id

type: long

Broker id

kafka.partition.broker.address

type: keyword

Broker address