4 references to MetricsService
Aspire.Confluent.Kafka (4)
AspireKafkaConsumerExtensions.cs (1)
128builder.Services.AddHostedService<MetricsService>();
AspireKafkaProducerExtensions.cs (1)
128builder.Services.AddHostedService<MetricsService>();
MetricsChannel.cs (1)
13/// The json processing is performed by <see cref="MetricsService"/>.
MetricsService.cs (1)
13internal sealed partial class MetricsService(MetricsChannel channel, ConfluentKafkaMetrics metrics, ILogger<MetricsService> logger) : BackgroundService