From 0ec95e4c8343880e6fcc76d0342bf99e6ce10344 Mon Sep 17 00:00:00 2001
From: liangshiwei <liangshiw@outlook.com>
Date: Fri, 2 Sep 2022 16:12:30 +0800
Subject: [PATCH] Fix Kafka connection problem

---
 framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ConsumerPool.cs | 2 +-
 framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ProducerPool.cs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ConsumerPool.cs b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ConsumerPool.cs
index 7147c81271..7c73df0d51 100644
--- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ConsumerPool.cs
+++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ConsumerPool.cs
@@ -37,7 +37,7 @@ public class ConsumerPool : IConsumerPool, ISingletonDependency
         return Consumers.GetOrAdd(
             connectionName, connection => new Lazy<IConsumer<string, byte[]>>(() =>
             {
-                var config = new ConsumerConfig(Options.Connections.GetOrDefault(connection))
+                var config = new ConsumerConfig(Options.Connections.GetOrDefault(connection).ToDictionary(k => k.Key, v => v.Value))
                 {
                     GroupId = groupId,
                     EnableAutoCommit = false
diff --git a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ProducerPool.cs b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ProducerPool.cs
index 691a29c1d2..ac2edf31a7 100644
--- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ProducerPool.cs
+++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/ProducerPool.cs
@@ -39,7 +39,7 @@ public class ProducerPool : IProducerPool, ISingletonDependency
         return Producers.GetOrAdd(
             connectionName, connection => new Lazy<IProducer<string, byte[]>>(() =>
             {
-                var producerConfig = new ProducerConfig(Options.Connections.GetOrDefault(connection));
+                var producerConfig = new ProducerConfig(Options.Connections.GetOrDefault(connection).ToDictionary(k => k.Key, v => v.Value));
                 Options.ConfigureProducer?.Invoke(producerConfig);
                 return new ProducerBuilder<string, byte[]>(producerConfig).Build();