Fix

masesgroup · Oct 11, 2023 · 914d430 · 914d430
1 parent a725458
commit 914d430
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/net/KEFCore/Infrastructure/Internal/KafkaSingletonOptions.cs b/src/net/KEFCore/Infrastructure/Internal/KafkaSingletonOptions.cs
@@ -46,10 +46,10 @@ public virtual void Initialize(IDbContextOptions options)
             DefaultNumPartitions = kafkaOptions.DefaultNumPartitions;
             DefaultConsumerInstances = kafkaOptions.DefaultConsumerInstances;
             DefaultReplicationFactor = kafkaOptions.DefaultReplicationFactor;
-            ConsumerConfigBuilder = ConsumerConfigBuilder.CreateFrom(kafkaOptions.ConsumerConfig);
-            ProducerConfigBuilder = ProducerConfigBuilder.CreateFrom(kafkaOptions.ProducerConfig);
+            ConsumerConfig = ConsumerConfigBuilder.CreateFrom(kafkaOptions.ConsumerConfig);
+            ProducerConfig = ProducerConfigBuilder.CreateFrom(kafkaOptions.ProducerConfig);
             StreamsConfig = StreamsConfigBuilder.CreateFrom(kafkaOptions.StreamsConfig);
-            TopicConfigBuilder = TopicConfigBuilder.CreateFrom(kafkaOptions.TopicConfig);
+            TopicConfig = TopicConfigBuilder.CreateFrom(kafkaOptions.TopicConfig);
         }
     }