From ba124c27fc2014cfeaba93b323958f12531ab3ad Mon Sep 17 00:00:00 2001
From: Kyle McClellan <kylemcclellan3@gmail.com>
Date: Thu, 9 Mar 2023 21:32:04 -0600
Subject: [PATCH] Bind options to config

---
 .../Confluent.Kafka.DependencyInjection.csproj                | 1 +
 .../ServiceCollectionExtensions.cs                            | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/Confluent.Kafka.DependencyInjection/Confluent.Kafka.DependencyInjection.csproj b/Confluent.Kafka.DependencyInjection/Confluent.Kafka.DependencyInjection.csproj
index bbe80ae..0082e0f 100644
--- a/Confluent.Kafka.DependencyInjection/Confluent.Kafka.DependencyInjection.csproj
+++ b/Confluent.Kafka.DependencyInjection/Confluent.Kafka.DependencyInjection.csproj
@@ -34,6 +34,7 @@
 
   <ItemGroup>
     <PackageReference Include="Confluent.Kafka" Version="*" />
+    <PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="*" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="*" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="*" />
     <PackageReference Include="Microsoft.Extensions.Options" Version="*" />
diff --git a/Confluent.Kafka.DependencyInjection/ServiceCollectionExtensions.cs b/Confluent.Kafka.DependencyInjection/ServiceCollectionExtensions.cs
index b31d1af..afd8a03 100644
--- a/Confluent.Kafka.DependencyInjection/ServiceCollectionExtensions.cs
+++ b/Confluent.Kafka.DependencyInjection/ServiceCollectionExtensions.cs
@@ -1,5 +1,6 @@
 namespace Confluent.Kafka.DependencyInjection;
 
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.DependencyInjection.Extensions;
 
@@ -20,7 +21,8 @@ public static IServiceCollection AddKafkaClient(
     {
         if (services == null) throw new ArgumentNullException(nameof(services));
 
-        services.AddOptions();
+        services.AddOptions<KafkaClientOptions>()
+            .Configure<IServiceProvider>((x, y) => y.GetService<IConfiguration>()?.GetSection("Kafka").Bind(x));
 
         if (configure != null)
         {