2 references to AttributeMessagingKafkaConsumerGroup
Aspire.Confluent.Kafka (2)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)
368activity.SetTag(SemanticConventions.AttributeMessagingKafkaConsumerGroup, this.GroupId);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
166activity.SetTag(SemanticConventions.AttributeMessagingKafkaConsumerGroup, groupId);