New

The executive guide to generative AI

Read more

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

Was this helpful?
Feedback