From 8d6bd0f0192a3b8580204e8c3841a02cc94506f9 Mon Sep 17 00:00:00 2001
From: Alexey Nikitin <kvandake@gmail.com>
Date: Mon, 29 Mar 2021 05:34:30 +0300
Subject: [PATCH] Add KafkaOptions.MainConfig to AutoCreateTopic (#810)

Co-authored-by: Alexey Nikitin <Aleksey.Nikitin@domrf.ru>
---
 src/DotNetCore.CAP.Kafka/IProcessingServer.AutoCreateTopic.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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();