1 reference to RecordReceive
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)
346
RecordReceive
(consumeResult.TopicPartitionOffset!.TopicPartition, duration, errorType);