New Redis connection per stream