kafkaflow/src/KafkaFlow.OpenTelemetry/AttributeKeys.cs at 3519a49edfdba1e391a2b52312e8f8d46e9bd395 · Farfetch/kafkaflow · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
namespace KafkaFlow.OpenTelemetry;

internal static class AttributeKeys
{
    public const string ClientId = "messaging.client.id";
    public const string ConsumerGroupName = "messaging.consumer.group.name";
    public const string DestinationName = "messaging.destination.name";
    public const string DestinationPartitionId = "messaging.destination.partition.id";
    public const string ErrorType = "error.type";
    public const string KafkaMessageKey = "messaging.kafka.message.key";
    public const string KafkaMessageTombstone = "messaging.kafka.message.tombstone";
    public const string KafkaOffset = "messaging.kafka.offset";
    public const string MessageBodySize = "messaging.message.body.size";
    public const string OperationName = "messaging.operation.name";
    public const string OperationType = "messaging.operation.type";
}