Merge pull request #60 from andyz-dev/atomic-create

[Enhancement] Atomic create

cli/commands.go

@@ -198,7 +198,12 @@ func CreateCluster(c *cli.Context) error {
 				c.Int("port-auto-offset"),
 			)
 			if err != nil {
-				return fmt.Errorf("ERROR: failed to create worker node for cluster %s\n%+v", c.String("name"), err)
+				log.Printf("ERROR: failed to create worker node for cluster %s\n%+v", c.String("name"), err)
+				delErr := DeleteCluster(c)
+				if delErr != nil {
+					return delErr
+				}
+				os.Exit(1)
 			}
 			log.Printf("Created worker with ID %s\n", workerID)
 		}