ExtractConsumeResult

3 references to ExtractConsumeResult

Aspire.Confluent.Kafka (3)

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

65(consumeResult, errorType) = ExtractConsumeResult(e); 92(consumeResult, errorType) = ExtractConsumeResult(e); 119(consumeResult, errorType) = ExtractConsumeResult(e);