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'