public static IWebJobsBuilder AddKafka()

in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Config/KafkaWebJobsBuilderExtensions.cs [20:43]

• 19 lines of code
• 3 McCabe index (conditional complexity)

        public static IWebJobsBuilder AddKafka(this IWebJobsBuilder builder, Action<KafkaOptions> configure)
        {
            if (builder == null)
            {
                throw new ArgumentNullException(nameof(builder));
            }

            if (configure == null)
            {
                throw new ArgumentNullException(nameof(configure));
            }

            builder.AddExtension<KafkaExtensionConfigProvider>()
                .BindOptions<KafkaOptions>();

            builder.Services.Configure<KafkaOptions>(options =>
            {
                configure(options);
            });

            builder.Services.AddSingleton<IKafkaProducerFactory, KafkaProducerFactory>();

            return builder;
        }