Implemented interface member:
1 reference to Consume
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (1)
101
var consumeResult = instrumentedConsumer.
Consume
(cancellationToken);