TopicPartitionOffset

2 references to TopicPartitionOffset

Aspire.Confluent.Kafka (2)

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

327using Activity? activity = this.StartReceiveActivity(propagationContext, startTime, consumeResult.TopicPartitionOffset, consumeResult.Key); 346RecordReceive(consumeResult.TopicPartitionOffset!.TopicPartition, duration, errorType);