1 reference to ConsumeAndProcessMessageAsync
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
62
ConsumeAndProcessMessageAsync
(consumer, handler, default);