in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/KafkaExtensionConfigProvider.cs [37:56]
public KafkaExtensionConfigProvider(
IConfiguration config,
IOptions<KafkaOptions> options,
ILoggerFactory loggerFactory,
IConverterManager converterManager,
INameResolver nameResolver,
IWebJobsExtensionConfiguration<KafkaExtensionConfigProvider> configuration,
IKafkaProducerFactory kafkaProducerFactory,
IDrainModeManager drainModeManager)
{
this.config = config;
this.options = options;
this.loggerFactory = loggerFactory;
this.converterManager = converterManager;
this.nameResolver = nameResolver;
this.configuration = configuration;
this.kafkaProducerFactory = kafkaProducerFactory;
this.logger = loggerFactory.CreateLogger(LogCategories.CreateTriggerCategory("Kafka"));
this.drainModeManager = drainModeManager;
}