KafkaIncubatingAttributes
in
Semantic attributes and corresponding values for kafka.
Tags
Table of Contents
Constants
- KAFKA_CLUSTER_ID : mixed = 'kafka.cluster.id'
- The Kafka cluster ID, obtained from the broker metadata exposed through the Kafka client (or AdminClient) API.
- KAFKA_MESSAGE_KEY : mixed = 'kafka.message.key'
- Message keys in Kafka are used for grouping alike messages to ensure they're processed on the same partition. They differ from `messaging.message.id` in that they're not unique. If the key is `null`, the attribute MUST NOT be set.
- KAFKA_MESSAGE_TOMBSTONE : mixed = 'kafka.message.tombstone'
- A boolean that is true if the message is a tombstone.
- KAFKA_OFFSET : mixed = 'kafka.offset'
- The offset of a record in the corresponding Kafka partition.
Constants
KAFKA_CLUSTER_ID
The Kafka cluster ID, obtained from the broker metadata exposed through the Kafka client (or AdminClient) API.
public
mixed
KAFKA_CLUSTER_ID
= 'kafka.cluster.id'
The cluster ID is a unique identifier reported by the Kafka broker. It identifies the cluster independently of the individual brokers the client is configured to connect to, and remains stable even if broker hostnames, IP addresses, or ports change.
Tags
KAFKA_MESSAGE_KEY
Message keys in Kafka are used for grouping alike messages to ensure they're processed on the same partition. They differ from `messaging.message.id` in that they're not unique. If the key is `null`, the attribute MUST NOT be set.
public
mixed
KAFKA_MESSAGE_KEY
= 'kafka.message.key'
If the key type is not string, its string representation has to be supplied for the attribute. If the key has no unambiguous, canonical string form, don't include its value.
Tags
KAFKA_MESSAGE_TOMBSTONE
A boolean that is true if the message is a tombstone.
public
mixed
KAFKA_MESSAGE_TOMBSTONE
= 'kafka.message.tombstone'
Tags
KAFKA_OFFSET
The offset of a record in the corresponding Kafka partition.
public
mixed
KAFKA_OFFSET
= 'kafka.offset'