From cb9075c1c0591abae33d7acf186f6c1c078f8b42 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jos=C3=A9=20Sousa?= <zpedro_s@hotmail.com>
Date: Sun, 6 Aug 2023 17:01:45 +0100
Subject: [PATCH] feat: improve admin config initialization

---
 src/KafkaFlow/Clusters/ClusterManager.cs | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/src/KafkaFlow/Clusters/ClusterManager.cs b/src/KafkaFlow/Clusters/ClusterManager.cs
index 96f2930a1..92a53b14b 100644
--- 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;