Node

Information about a Kafka cluster node

Name

Type

Description

@empty

Boolean

@hasRack

Boolean

Set if this node has a defined rack

@host

String

Set the host name for this node

@id

Number (int)

Set the node id of this node

@idString

String

Set the string representation of the node id

@isEmpty

Boolean

Set if this node is empty

@port

Number (int)

Set the port for this node

@rack

String

Set the rack for this node

OffsetAndMetadata

Provide additional metadata when an offset is committed

Name

Type

Description

@metadata

String

Set additional metadata for the offset committed

@offset

Number (long)

Set the offset to commit

OffsetAndTimestamp

Represent information related to a Offset with timestamp information

Name

Type

Description

@offset

Number (long)

Set the offset

@timestamp

Number (long)

Set the timestamp

PartitionInfo

Information about a specific Kafka topic partition

Name

Type

Description

@inSyncReplicas

Array of Node

Set the subset of the replicas that are in sync

@leader

Node

Set the node id of the node currently acting as a leader

@partition

Number (int)

Set the partition id

@replicas

Array of Node

Set the complete set of replicas for this partition

@topic

String

Set the topic name

RecordMetadata

Metadata related to a Kafka record

Name

Type

Description

@checksum

Number (long)

Set the checksum (CRC32) of the record.

@offset

Number (long)

Set the offset of the record in the topic/partition.

@partition

Number (int)

Set the partition the record was sent to

@timestamp

Number (long)

Set the timestamp of the record in the topic/partition

@topic

String

Set the topic the record was appended to

TopicPartition

Represent information related to a partition for a topic

Name

Type

Description

@partition

Number (int)

Set the partition number

@topic

String

Set the topic name