diff --git a/cryptofeed/backends/redis.py b/cryptofeed/backends/redis.py
index eb43a5cdc..3240c8294 100644
--- a/cryptofeed/backends/redis.py
+++ b/cryptofeed/backends/redis.py
@@ -29,6 +29,7 @@ def __init__(self, host='127.0.0.1', port=6379, socket=None, key=None, none_to='
         self.numeric_type = numeric_type
         self.none_to = none_to
         self.running = True
+        self.conn_kwargs = kwargs
 
 
 class RedisZSetCallback(RedisCallback):
@@ -43,7 +44,7 @@ def __init__(self, host='127.0.0.1', port=6379, socket=None, key=None, numeric_t
         super().__init__(host=host, port=port, socket=socket, key=key, numeric_type=numeric_type, **kwargs)
 
     async def writer(self):
-        conn = aioredis.from_url(self.redis)
+        conn = aioredis.from_url(self.redis, **self.conn_kwargs)
 
         while self.running:
             async with self.read_queue() as updates:
@@ -58,7 +59,7 @@ async def writer(self):
 
 class RedisStreamCallback(RedisCallback):
     async def writer(self):
-        conn = aioredis.from_url(self.redis)
+        conn = aioredis.from_url(self.redis, **self.conn_kwargs)
 
         while self.running:
             async with self.read_queue() as updates:
@@ -81,7 +82,7 @@ async def writer(self):
 class RedisKeyCallback(RedisCallback):
 
     async def writer(self):
-        conn = aioredis.from_url(self.redis)
+        conn = aioredis.from_url(self.redis, **self.conn_kwargs)
 
         while self.running:
             async with self.read_queue() as updates: