15 references to ConfluentKafkaCommon
Aspire.Confluent.Kafka (15)
AspireKafkaConsumerExtensions.cs (7)
138if (ConfluentKafkaCommon.IsAspire8ConfluentKafkaMetricsEnabled) 147if (ConfluentKafkaCommon.IsAspire8ConfluentKafkaMetricsEnabled) 149metricBuilderProvider.AddMeter(ConfluentKafkaCommon.MeterName); 167? ConfluentKafkaCommon.ConsumerHealthCheckName 168: string.Concat(ConfluentKafkaCommon.KeyedConsumerHealthCheckName, connectionName); 206ILogger logger = serviceProvider.GetRequiredService<ILoggerFactory>().CreateLogger(ConfluentKafkaCommon.LogCategoryName); 221if (!settings.DisableMetrics && ConfluentKafkaCommon.IsAspire8ConfluentKafkaMetricsEnabled)
AspireKafkaProducerExtensions.cs (7)
138if (ConfluentKafkaCommon.IsAspire8ConfluentKafkaMetricsEnabled) 147if (ConfluentKafkaCommon.IsAspire8ConfluentKafkaMetricsEnabled) 149metricBuilderProvider.AddMeter(ConfluentKafkaCommon.MeterName); 167? ConfluentKafkaCommon.ProducerHealthCheckName 168: string.Concat(ConfluentKafkaCommon.KeyedProducerHealthCheckName, connectionName); 206ILogger logger = serviceProvider.GetRequiredService<ILoggerFactory>().CreateLogger(ConfluentKafkaCommon.LogCategoryName); 221if (!settings.DisableMetrics && ConfluentKafkaCommon.IsAspire8ConfluentKafkaMetricsEnabled)
ConfluentKafkaMetrics.cs (1)
28_meter = meterFactory.Create(ConfluentKafkaCommon.MeterName);