GroupId

1 write to GroupId

Aspire.Confluent.Kafka (1)

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumerBuilder.cs (1)

47consumer.GroupId = config.GroupId;

3 references to GroupId

Aspire.Confluent.Kafka (3)

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)

368activity.SetTag(SemanticConventions.AttributeMessagingKafkaConsumerGroup, this.GroupId);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (2)

116instrumentedConsumer.GroupId!); 125instrumentedConsumer.GroupId!);