Kafka fields

edit

Kafka module

kafka

edit

broker

edit

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

kafka.broker.id

Broker id

type: long

kafka.broker.address

Broker advertised address

type: keyword

kafka.topic.name

Topic name

type: keyword

kafka.topic.error.code

Topic error code.

type: long

kafka.partition.id

Partition id.

type: long

kafka.partition.topic_id

Unique id of the partition in the topic.

type: keyword

kafka.partition.topic_broker_id

Unique id of the partition in the topic and the broker.

type: keyword

consumergroup

edit

consumergroup

broker

edit

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

kafka.consumergroup.broker.id

Broker id

type: long

kafka.consumergroup.broker.address

Broker address

type: keyword

kafka.consumergroup.id

Consumer Group ID

type: keyword

kafka.consumergroup.topic

[6.5] Deprecated in 6.5.

Topic name

type: keyword

kafka.consumergroup.partition

[6.5] Deprecated in 6.5.

Partition ID

type: long

kafka.consumergroup.offset

consumer offset into partition being read

type: long

kafka.consumergroup.meta

custom consumer meta data string

type: keyword

kafka.consumergroup.error.code

kafka consumer/partition error code.

type: long

client

edit

Assigned client reading events from partition

kafka.consumergroup.client.id

Client ID (kafka setting client.id)

type: keyword

kafka.consumergroup.client.host

Client host

type: keyword

kafka.consumergroup.client.member_id

internal consumer group member ID

type: keyword

partition

edit

partition

offset

edit

Available offsets of the given partition.

kafka.partition.offset.newest

Newest offset of the partition.

type: long

kafka.partition.offset.oldest

Oldest offset of the partition.

type: long

partition

edit

Partition data.

kafka.partition.partition.id

[6.5] Deprecated in 6.5.

Partition id.

type: long

kafka.partition.partition.leader

Leader id (broker).

type: long

kafka.partition.partition.isr

List of isr ids.

type: keyword

kafka.partition.partition.replica

Replica id (broker).

type: long

kafka.partition.partition.insync_replica

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

type: boolean

kafka.partition.partition.is_leader

Indicates if replica is the leader

type: boolean

kafka.partition.partition.error.code

Error code from fetching partition.

type: long

kafka.partition.topic.error.code

[6.5] Deprecated in 6.5.

topic error code.

type: long

kafka.partition.topic.name

[6.5] Deprecated in 6.5.

Topic name

type: keyword

kafka.partition.broker.id

[6.5] Deprecated in 6.5.

Broker id

type: long

kafka.partition.broker.address

[6.5] Deprecated in 6.5.

Broker address

type: keyword