Module: Datadog::Tracing::Contrib::Karafka::Ext

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

Constant Summary collapse

ENV_ENABLED =
"DD_TRACE_KARAFKA_ENABLED"
ENV_DISTRIBUTED_TRACING =
"DD_TRACE_KARAFKA_DISTRIBUTED_TRACING"
SPAN_MESSAGE_CONSUME =
"karafka.consume"
SPAN_WORKER_PROCESS =
"worker.process"
TAG_CONSUMER =
"kafka.consumer"
TAG_TOPIC =
"kafka.topic"
TAG_PARTITION =
"kafka.partition"
TAG_OFFSET =
"kafka.offset"
TAG_OFFSET_LAG =
"kafka.offset_lag"
TAG_MESSAGE_COUNT =
"kafka.message_count"
TAG_MESSAGE_KEY =
"kafka.message_key"
TAG_SYSTEM =
"kafka"
TAG_OPERATION_PROCESS_BATCH =
"consumer.process_batch"