1 write to producer
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (1)
22
this.
producer
= producer;
19 references to producer
Aspire.Confluent.Kafka (19)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (19)
26
public Handle Handle => this.
producer
.Handle;
28
public string Name => this.
producer
.Name;
32
return this.
producer
.AddBrokers(brokers);
37
this.
producer
.SetSaslCredentials(username, password);
56
result = await this.
producer
.ProduceAsync(topic, message, cancellationToken).ConfigureAwait(false);
103
result = await this.
producer
.ProduceAsync(topicPartition, message, cancellationToken).ConfigureAwait(false);
146
this.
producer
.Produce(topic, message, deliveryHandler);
187
this.
producer
.Produce(topicPartition, message, deliveryHandler);
218
return this.
producer
.Poll(timeout);
223
return this.
producer
.Flush(timeout);
228
this.
producer
.Flush(cancellationToken);
233
this.
producer
.InitTransactions(timeout);
238
this.
producer
.BeginTransaction();
243
this.
producer
.CommitTransaction(timeout);
248
this.
producer
.CommitTransaction();
253
this.
producer
.AbortTransaction(timeout);
258
this.
producer
.AbortTransaction();
263
this.
producer
.SendOffsetsToTransaction(offsets, groupMetadata, timeout);
268
this.
producer
.Dispose();