diff --git a/pubsub/redis/redis.go b/pubsub/redis/redis.go
index b3c915a63..ec330f86e 100644
--- a/pubsub/redis/redis.go
+++ b/pubsub/redis/redis.go
@@ -399,7 +399,7 @@ func (r *redisStreams) removeMessagesThatNoLongerExistFromPending(ctx context.Co
 			Stream:   stream,
 			Group:    r.metadata.consumerID,
 			Consumer: r.metadata.consumerID,
-			MinIdle:  r.metadata.processingTimeout,
+			MinIdle:  0,
 			Messages: []string{pendingID},
 		}).Result()
 		if err != nil && !errors.Is(err, redis.Nil) {