feat: improve admin config initialization

Farfetch · Sep 15, 2023 · cb9075c · cb9075c
1 parent 4941614
commit cb9075c
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/src/KafkaFlow/Clusters/ClusterManager.cs b/src/KafkaFlow/Clusters/ClusterManager.cs
@@ -13,16 +13,22 @@ internal class ClusterManager : IClusterManager
         private readonly ILogHandler logHandler;
         private readonly Lazy<AdminClientBuilder> lazyAdminClientBuilder;
         private readonly ClusterConfiguration configuration;
-        private readonly ClientConfig clientConfig = new();
 
         public ClusterManager(ILogHandler logHandler, ClusterConfiguration configuration)
         {
             this.logHandler = logHandler;
             this.configuration = configuration;
-            this.clientConfig.ReadSecurityInformationFrom(this.configuration);
             this.lazyAdminClientBuilder = new Lazy<AdminClientBuilder>(
-                () => new AdminClientBuilder(new AdminClientConfig(this.clientConfig)
-                { BootstrapServers = string.Join(",", configuration.Brokers) }));
+                () =>
+                {
+                    var adminConfig = new AdminClientConfig()
+                    {
+                        BootstrapServers = string.Join(",", configuration.Brokers),
+                    };
+                    adminConfig.ReadSecurityInformationFrom(configuration);
+
+                    return new AdminClientBuilder(adminConfig);
+                });
         }
 
         public string ClusterName => this.configuration.Name;