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