15 references to ConfluentKafkaCommon
Aspire.Confluent.Kafka (15)
AspireKafkaConsumerExtensions.cs (7)
131
if (
ConfluentKafkaCommon
.IsAspire8ConfluentKafkaMetricsEnabled)
140
if (
ConfluentKafkaCommon
.IsAspire8ConfluentKafkaMetricsEnabled)
142
metricBuilderProvider.AddMeter(
ConfluentKafkaCommon
.MeterName);
160
?
ConfluentKafkaCommon
.ConsumerHealthCheckName
161
: string.Concat(
ConfluentKafkaCommon
.KeyedConsumerHealthCheckName, connectionName);
199
ILogger logger = serviceProvider.GetRequiredService<ILoggerFactory>().CreateLogger(
ConfluentKafkaCommon
.LogCategoryName);
214
if (!settings.DisableMetrics &&
ConfluentKafkaCommon
.IsAspire8ConfluentKafkaMetricsEnabled)
AspireKafkaProducerExtensions.cs (7)
131
if (
ConfluentKafkaCommon
.IsAspire8ConfluentKafkaMetricsEnabled)
140
if (
ConfluentKafkaCommon
.IsAspire8ConfluentKafkaMetricsEnabled)
142
metricBuilderProvider.AddMeter(
ConfluentKafkaCommon
.MeterName);
160
?
ConfluentKafkaCommon
.ProducerHealthCheckName
161
: string.Concat(
ConfluentKafkaCommon
.KeyedProducerHealthCheckName, connectionName);
199
ILogger logger = serviceProvider.GetRequiredService<ILoggerFactory>().CreateLogger(
ConfluentKafkaCommon
.LogCategoryName);
214
if (!settings.DisableMetrics &&
ConfluentKafkaCommon
.IsAspire8ConfluentKafkaMetricsEnabled)
ConfluentKafkaMetrics.cs (1)
28
_meter = meterFactory.Create(
ConfluentKafkaCommon
.MeterName);