modules/JiShe.CollectBus.Kafka/AdminClient/AdminClientService.cs

@@ -8,11 +8,10 @@ using Volo.Abp.DependencyInjection;
 
 namespace JiShe.CollectBus.Kafka.AdminClient;
 
-public class AdminClientService : IAdminClientService, ISingletonDependency
+public class AdminClientService : IAdminClientService, IDisposable, ISingletonDependency
 {
     private readonly ILogger<AdminClientService> _logger;
     private readonly KafkaOptionConfig _kafkaOptionConfig;
-    private readonly Lazy<IAdminClient> _lazyAdminClient;
     /// <summary>
     /// Initializes a new instance of the <see cref="AdminClientService" /> class.
     /// </summary>
@@ -22,8 +21,7 @@ public class AdminClientService : IAdminClientService, ISingletonDependency
     {
         _logger = logger;
         _kafkaOptionConfig = kafkaOptionConfig.Value;
-        //Instance = GetInstance();
-        _lazyAdminClient = new Lazy<IAdminClient>(() => GetInstance());
+        Instance = GetInstance();
     }
 
     /// <summary>
@@ -32,7 +30,7 @@ public class AdminClientService : IAdminClientService, ISingletonDependency
     /// <value>
     ///     The instance.
     /// </value>
-    public IAdminClient Instance => _lazyAdminClient.Value;
+    public IAdminClient Instance { get; set; }
 
     /// <summary>
     /// 创建Kafka主题
@@ -139,6 +137,11 @@ public class AdminClientService : IAdminClientService, ISingletonDependency
         return metadata.Topics[0].Partitions.Count;
     }
 
+    public void Dispose()
+    {
+        Instance?.Dispose();
+    }
+
     /// <summary>
     ///     Gets the instance.
     /// </summary>