4 references to ConfluentKafkaMetrics
Aspire.Confluent.Kafka (4)
AspireKafkaConsumerExtensions.cs (1)
129
builder.Services.TryAddSingleton<
ConfluentKafkaMetrics
>();
AspireKafkaProducerExtensions.cs (1)
129
builder.Services.TryAddSingleton<
ConfluentKafkaMetrics
>();
MetricsService.cs (2)
9
using static Aspire.Confluent.Kafka.
ConfluentKafkaMetrics
;
13
internal sealed partial class MetricsService(MetricsChannel channel,
ConfluentKafkaMetrics
metrics, ILogger<MetricsService> logger) : BackgroundService