Module: Datadog::Tracing::Contrib::Kafka::Ext

Defined in:

lib/datadog/tracing/contrib/kafka/ext.rb,
sig/datadog/tracing/contrib/kafka/ext.rbs

Overview

Kafka integration constants

Constant Summary

ENV_ENABLED =

Returns:

• ("DD_TRACE_KAFKA_ENABLED")

"DD_TRACE_KAFKA_ENABLED"

ENV_ANALYTICS_ENABLED =

Returns:

• ("DD_TRACE_KAFKA_ANALYTICS_ENABLED")

"DD_TRACE_KAFKA_ANALYTICS_ENABLED"

ENV_ANALYTICS_SAMPLE_RATE =

Returns:

• ("DD_TRACE_KAFKA_ANALYTICS_SAMPLE_RATE")

"DD_TRACE_KAFKA_ANALYTICS_SAMPLE_RATE"

SPAN_CONNECTION_REQUEST =

Returns:

• ("kafka.connection.request")

"kafka.connection.request"

SPAN_CONSUMER_HEARTBEAT =

Returns:

• ("kafka.consumer.heartbeat")

"kafka.consumer.heartbeat"

SPAN_CONSUMER_JOIN_GROUP =

Returns:

• ("kafka.consumer.join_group")

"kafka.consumer.join_group"

SPAN_CONSUMER_LEAVE_GROUP =

Returns:

• ("kafka.consumer.leave_group")

"kafka.consumer.leave_group"

SPAN_CONSUMER_SYNC_GROUP =

Returns:

• ("kafka.consumer.sync_group")

"kafka.consumer.sync_group"

SPAN_DELIVER_MESSAGES =

Returns:

• ("kafka.producer.deliver_messages")

"kafka.producer.deliver_messages"

SPAN_PROCESS_BATCH =

Returns:

• ("kafka.consumer.process_batch")

"kafka.consumer.process_batch"

SPAN_PROCESS_MESSAGE =

Returns:

• ("kafka.consumer.process_message")

"kafka.consumer.process_message"

SPAN_SEND_MESSAGES =

Returns:

• ("kafka.producer.send_messages")

"kafka.producer.send_messages"

TAG_ATTEMPTS =

Returns:

• ("kafka.attempts")

"kafka.attempts"

TAG_API =

Returns:

• ("kafka.api")

"kafka.api"

TAG_CLIENT =

Returns:

• ("kafka.client")

"kafka.client"

TAG_GROUP =

Returns:

• ("kafka.group")

"kafka.group"

TAG_HIGHWATER_MARK_OFFSET =

Returns:

• ("kafka.highwater_mark_offset")

"kafka.highwater_mark_offset"

TAG_MESSAGE_COUNT =

Returns:

• ("kafka.message_count")

"kafka.message_count"

TAG_MESSAGE_KEY =

Returns:

• ("kafka.message_key")

"kafka.message_key"

TAG_DELIVERED_MESSAGE_COUNT =

Returns:

• ("kafka.delivered_message_count")

"kafka.delivered_message_count"

TAG_OFFSET =

Returns:

• ("kafka.offset")

"kafka.offset"

TAG_OFFSET_LAG =

Returns:

• ("kafka.offset_lag")

"kafka.offset_lag"

TAG_PARTITION =

Returns:

• ("kafka.partition")

"kafka.partition"

TAG_REQUEST_SIZE =

Returns:

• ("kafka.request_size")

"kafka.request_size"

TAG_RESPONSE_SIZE =

Returns:

• ("kafka.response_size")

"kafka.response_size"

TAG_SENT_MESSAGE_COUNT =

Returns:

• ("kafka.sent_message_count")

"kafka.sent_message_count"

TAG_TOPIC =

Returns:

• ("kafka.topic")

"kafka.topic"

TAG_TOPIC_PARTITIONS =

Returns:

• ("kafka.topic_partitions")

"kafka.topic_partitions"

TAG_COMPONENT =

Returns:

• ("kafka")

"kafka"

TAG_OPERATION_CONNECTION_REQUEST =

Returns:

• ("connection.request")

"connection.request"

TAG_OPERATION_CONSUMER_HEARTBEAT =

Returns:

• ("consumer.heartbeat")

"consumer.heartbeat"

TAG_OPERATION_CONSUMER_JOIN_GROUP =

Returns:

• ("consumer.join_group")

"consumer.join_group"

TAG_OPERATION_CONSUMER_LEAVE_GROUP =

Returns:

• ("consumer.leave_group")

"consumer.leave_group"

TAG_OPERATION_CONSUMER_SYNC_GROUP =

Returns:

• ("consumer.sync_group")

"consumer.sync_group"

TAG_OPERATION_DELIVER_MESSAGES =

Returns:

• ("producer.deliver_messages")

"producer.deliver_messages"

TAG_OPERATION_PROCESS_BATCH =

Returns:

• ("consumer.process_batch")

"consumer.process_batch"

TAG_OPERATION_PROCESS_MESSAGE =

Returns:

• ("consumer.process_message")

"consumer.process_message"

TAG_OPERATION_SEND_MESSAGES =

Returns:

• ("producer.send_messages")

"producer.send_messages"

TAG_MESSAGING_SYSTEM =

Returns:

• ("kafka")

"kafka"

TAG_KAFKA_BOOTSTRAP_SERVERS =

Returns:

• ("messaging.kafka.bootstrap.servers")

"messaging.kafka.bootstrap.servers"