4 references to StartPublishActivity
Aspire.Confluent.Kafka (4)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (4)
46using Activity? activity = this.StartPublishActivity(start, topic, message); 93using Activity? activity = this.StartPublishActivity(start, topicPartition.Topic, message, topicPartition.Partition); 137using Activity? activity = this.StartPublishActivity(start, topic, message); 178using Activity? activity = this.StartPublishActivity(start, topicPartition.Topic, message, topicPartition.Partition);