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

Overview

Kafka integration constants

ENV_ENABLED =

"DD_TRACE_KAFKA_ENABLED"

ENV_ANALYTICS_SAMPLE_RATE =

"DD_TRACE_KAFKA_ANALYTICS_SAMPLE_RATE"

SPAN_CONNECTION_REQUEST =

"kafka.connection.request"

SPAN_CONSUMER_HEARTBEAT =

"kafka.consumer.heartbeat"

SPAN_CONSUMER_JOIN_GROUP =

"kafka.consumer.join_group"

SPAN_CONSUMER_LEAVE_GROUP =

"kafka.consumer.leave_group"

SPAN_CONSUMER_SYNC_GROUP =

"kafka.consumer.sync_group"

SPAN_DELIVER_MESSAGES =

"kafka.producer.deliver_messages"

SPAN_PROCESS_BATCH =

"kafka.consumer.process_batch"

SPAN_PROCESS_MESSAGE =

"kafka.consumer.process_message"

SPAN_SEND_MESSAGES =

"kafka.producer.send_messages"

TAG_ATTEMPTS =

"kafka.attempts"

TAG_API =

"kafka.api"

TAG_CLIENT =

"kafka.client"

TAG_GROUP =

"kafka.group"

TAG_HIGHWATER_MARK_OFFSET =

"kafka.highwater_mark_offset"

TAG_MESSAGE_COUNT =

"kafka.message_count"

TAG_MESSAGE_KEY =

"kafka.message_key"

TAG_DELIVERED_MESSAGE_COUNT =

"kafka.delivered_message_count"

TAG_OFFSET =

"kafka.offset"

TAG_OFFSET_LAG =

"kafka.offset_lag"

TAG_PARTITION =

"kafka.partition"

TAG_REQUEST_SIZE =

"kafka.request_size"

TAG_RESPONSE_SIZE =

"kafka.response_size"

TAG_SENT_MESSAGE_COUNT =

"kafka.sent_message_count"

TAG_TOPIC =

"kafka.topic"

TAG_TOPIC_PARTITIONS =

"kafka.topic_partitions"

TAG_COMPONENT =

"kafka"

TAG_OPERATION_CONNECTION_REQUEST =

"connection.request"

TAG_OPERATION_CONSUMER_HEARTBEAT =

"consumer.heartbeat"

TAG_OPERATION_CONSUMER_JOIN_GROUP =

"consumer.join_group"

TAG_OPERATION_CONSUMER_LEAVE_GROUP =

"consumer.leave_group"

TAG_OPERATION_CONSUMER_SYNC_GROUP =

"consumer.sync_group"

TAG_OPERATION_DELIVER_MESSAGES =

"producer.deliver_messages"

TAG_OPERATION_PROCESS_BATCH =

"consumer.process_batch"

TAG_OPERATION_PROCESS_MESSAGE =

"consumer.process_message"

TAG_OPERATION_SEND_MESSAGES =

"producer.send_messages"

TAG_MESSAGING_SYSTEM =

"kafka"

TAG_KAFKA_BOOTSTRAP_SERVERS =

"messaging.kafka.bootstrap.servers"