Kafka fields

Kafka module

kafka fields

broker fields

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

kafka.broker.id

type: long

Broker id

kafka.broker.address

type: keyword

Broker advertised address

kafka.topic.name

type: keyword

Topic name

kafka.topic.error.code

type: long

Topic error code.

kafka.partition.id

type: long

Partition id.

kafka.partition.topic_id

type: keyword

Unique id of the partition in the topic.

kafka.partition.topic_broker_id

type: keyword

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

consumergroup fields

consumergroup

broker fields

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

kafka.consumergroup.broker.id

type: long

Broker id

kafka.consumergroup.broker.address

type: keyword

Broker address

kafka.consumergroup.id

type: keyword

Consumer Group ID

kafka.consumergroup.topic

[6.5] Deprecated in 6.5.

type: keyword

Topic name

kafka.consumergroup.partition

[6.5] Deprecated in 6.5.

type: long

Partition ID

kafka.consumergroup.offset

type: long

consumer offset into partition being read

kafka.consumergroup.meta

type: text

custom consumer meta data string

kafka.consumergroup.error.code

type: long

kafka consumer/partition error code.

client fields

Assigned client reading events from partition

kafka.consumergroup.client.id

type: keyword

Client ID (kafka setting client.id)

kafka.consumergroup.client.host

type: keyword

Client host

kafka.consumergroup.client.member_id

type: keyword

internal consumer group member ID

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

[6.5] Deprecated in 6.5.

type: long

Partition id.

kafka.partition.partition.leader

type: long

Leader id (broker).

kafka.partition.partition.isr

type: array

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.is_leader

type: boolean

Indicates if replica is the leader

kafka.partition.partition.error.code

type: long

Error code from fetching partition.

kafka.partition.topic.error.code

[6.5] Deprecated in 6.5.

type: long

topic error code.

kafka.partition.topic.name

[6.5] Deprecated in 6.5.

type: keyword

Topic name

kafka.partition.broker.id

[6.5] Deprecated in 6.5.

type: long

Broker id

kafka.partition.broker.address

[6.5] Deprecated in 6.5.

type: keyword

Broker address