9 references to ConfluentKafkaCommon
Aspire.Confluent.Kafka (9)
AspireKafkaConsumerExtensions.cs (4)
130
builder.Services.AddOpenTelemetry().WithMetrics(metricBuilderProvider => metricBuilderProvider.AddMeter(
ConfluentKafkaCommon
.MeterName));
136
?
ConfluentKafkaCommon
.ConsumerHealthCheckName
137
: string.Concat(
ConfluentKafkaCommon
.KeyedConsumerHealthCheckName, connectionName);
169
ILogger logger = serviceProvider.GetRequiredService<ILoggerFactory>().CreateLogger(
ConfluentKafkaCommon
.LogCategoryName);
AspireKafkaProducerExtensions.cs (4)
130
builder.Services.AddOpenTelemetry().WithMetrics(metricBuilderProvider => metricBuilderProvider.AddMeter(
ConfluentKafkaCommon
.MeterName));
136
?
ConfluentKafkaCommon
.ProducerHealthCheckName
137
: string.Concat(
ConfluentKafkaCommon
.KeyedProducerHealthCheckName, connectionName);
169
ILogger logger = serviceProvider.GetRequiredService<ILoggerFactory>().CreateLogger(
ConfluentKafkaCommon
.LogCategoryName);
ConfluentKafkaMetrics.cs (1)
28
_meter = meterFactory.Create(
ConfluentKafkaCommon
.MeterName);