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

Defined in:
lib/datadog/tracing/contrib/kafka/ext.rb

Overview

Kafka integration constants

Constant Summary collapse

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'