IMPORTANT: No additional bug fixes or documentation updates will be released for this version. For the latest information, see the current release documentation.

› ›

Kafka fields

edit

Kafka fields

edit

Kafka module

kafka fields

edit

broker fields

edit

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

edit

consumergroup

broker fields

edit

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

edit

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

edit

partition

offset fields

edit

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

edit

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

« Jolokia fields Kibana fields »