rpk: change exit status for topic command failures

src/go/rpk/pkg/cli/cmd/topic/add_partitions.go

@@ -11,6 +11,7 @@ package topic
 
 import (
 	"context"
+	"os"
 
 	"github.com/redpanda-data/redpanda/src/go/rpk/pkg/config"
 	"github.com/redpanda-data/redpanda/src/go/rpk/pkg/kafka"
@@ -42,13 +43,21 @@ func NewAddPartitionsCommand(fs afero.Fs) *cobra.Command {
 			resps, err := adm.CreatePartitions(context.Background(), num, topics...)
 			out.MaybeDie(err, "create partitions request failed: %v", err)
 
+			var exit1 bool
+			defer func() {
+				if exit1 {
+					os.Exit(1)
+				}
+			}()
+
 			tw := out.NewTable("topic", "error")
 			defer tw.Flush()
 
 			for _, resp := range resps.Sorted() {
 				msg := "OK"
 				if e := resp.Err; e != nil {
 					msg = e.Error()
+					exit1 = true
 				}
 				tw.Print(resp.Topic, msg)
 			}

src/go/rpk/pkg/cli/cmd/topic/create.go

@@ -11,6 +11,7 @@ package topic
 
 import (
 	"context"
+	"os"
 
 	"github.com/redpanda-data/redpanda/src/go/rpk/pkg/config"
 	"github.com/redpanda-data/redpanda/src/go/rpk/pkg/kafka"
@@ -85,13 +86,21 @@ the cleanup.policy=compact config option set.
 			resp, err := req.RequestWith(context.Background(), cl)
 			out.MaybeDie(err, "unable to create topics %v: %v", topics, err)
 
+			var exit1 bool
+			defer func() {
+				if exit1 {
+					os.Exit(1)
+				}
+			}()
+
 			tw := out.NewTable("topic", "status")
 			defer tw.Flush()
 
 			for _, topic := range resp.Topics {
 				msg := "OK"
 				if err := kerr.ErrorForCode(topic.ErrorCode); err != nil {
 					msg = err.Error()
+					exit1 = true
 				}
 				tw.Print(topic.Topic, msg)
 			}