diff --git a/stream/transport/redis/redis.go b/stream/transport/redis/redis.go
index d1c5136c..54fdec84 100644
--- a/stream/transport/redis/redis.go
+++ b/stream/transport/redis/redis.go
@@ -37,6 +37,7 @@ func (t *Topic) Publish(ctx context.Context, m transport.Message) error {
 
 func (t *Topic) Subscribe(ctx context.Context) transport.Subscription {
 	return Subscription{
+		Logger:    t.Logger,
 		PubSub:    t.Redis.Subscribe(ctx, t.Name),
 		LocalNode: t.LocalNode,
 	}