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

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'