diff --git a/packages/apalis-redis/src/storage.rs b/packages/apalis-redis/src/storage.rs
index 9a85718..b12e198 100644
--- a/packages/apalis-redis/src/storage.rs
+++ b/packages/apalis-redis/src/storage.rs
@@ -632,6 +632,11 @@ where
             }
             Err(e) => {
                 warn!("An error occurred during streaming jobs: {e}");
+                if matches!(e.kind(), ErrorKind::ResponseError)
+                    && e.to_string().contains("consumer not registered script")
+                {
+                    self.keep_alive(worker_id).await?;
+                }
                 Err(e)
             }
         }