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

Overview

Kafka integration constants

ENV_ENABLED =

'DD_TRACE_KAFKA_ENABLED'

ENV_ANALYTICS_ENABLED =

'DD_TRACE_KAFKA_ANALYTICS_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'