Bind options to config

kmcclellan · Mar 10, 2023 · ba124c2 · ba124c2
1 parent 24f8b96
commit ba124c2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git 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
@@ -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)
         {