diff --git a/src/DotNetCore.CAP.Kafka/IProcessingServer.AutoCreateTopic.cs b/src/DotNetCore.CAP.Kafka/IProcessingServer.AutoCreateTopic.cs
index fcf9874..2b784ff 100644
--- a/src/DotNetCore.CAP.Kafka/IProcessingServer.AutoCreateTopic.cs
+++ b/src/DotNetCore.CAP.Kafka/IProcessingServer.AutoCreateTopic.cs
@@ -31,7 +31,7 @@ namespace DotNetCore.CAP.Kafka
         {
             try
             {
-                var config = new AdminClientConfig { BootstrapServers = _kafkaOptions.Servers };
+                var config = new AdminClientConfig(_kafkaOptions.MainConfig) { BootstrapServers = _kafkaOptions.Servers };
 
                 var topics = _selector.GetAllTopics();