diff --git a/core/StreamConfig.cs b/core/StreamConfig.cs
index c92ab851..664f06c9 100644
--- a/core/StreamConfig.cs
+++ b/core/StreamConfig.cs
@@ -2282,7 +2282,7 @@ public StreamConfig()
         /// </para>
         /// </summary>
         /// <param name="properties">Dictionary of stream properties</param>
-        public StreamConfig(IDictionary<string, dynamic> properties)
+        public StreamConfig(IDictionary<string, dynamic> properties, ILoggerFactory loggerFactory = null)
         {
             InitializeReflectedProperties();
             
@@ -2329,17 +2329,22 @@ public StreamConfig(IDictionary<string, dynamic> properties)
             PartitionAssignmentStrategy = Confluent.Kafka.PartitionAssignmentStrategy.Range;
             Partitioner = Confluent.Kafka.Partitioner.Murmur2Random;
 
-            Logger = LoggerFactory.Create(builder =>
-            {
-                builder.SetMinimumLevel(LogLevel.Information);
-                builder.AddConsole();
-            });
-            
+            Logger = loggerFactory;
+
             if (properties != null)
             {
                 foreach (var k in properties)
                     AddConfig(k.Key, k.Value);
             }
+
+            if (Logger != null)
+                return;
+
+            Logger = LoggerFactory.Create(builder =>
+            {
+                builder.SetMinimumLevel(LogLevel.Information);
+                builder.AddConsole();
+            });
         }
 
         #endregion
@@ -3403,8 +3408,9 @@ public StreamConfig() : this(null) { }
         /// </para>
         /// </summary>
         /// <param name="properties">Dictionary of stream properties</param>
-        public StreamConfig(IDictionary<string, dynamic> properties)
-            : base(properties)
+        /// <param name="loggerFactory">LoggerFactory for creating loggers. If not provided new instance will be created</param>
+        public StreamConfig(IDictionary<string, dynamic> properties, ILoggerFactory loggerFactory = null)
+            : base(properties, loggerFactory)
         {
             DefaultKeySerDes = new KS();
             DefaultValueSerDes = new VS();