@@ -115,6 +115,8 @@ j.cancelMu.Unlock()
 
 		if err := j.client.ConnectAndRead(connCtx, cursor); err != nil {
 			l.Error("error reading jetstream", "error", err)
+			cancel()
+			continue
 		}
 
 		select {