TEMP: rpk logs

redpanda-data · Jun 15, 2022 · 3cf5944 · 3cf5944
1 parent 8934dcd
commit 3cf5944
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/go/rpk/pkg/cli/cmd/topic/create.go b/src/go/rpk/pkg/cli/cmd/topic/create.go
@@ -22,6 +22,7 @@ import (
 	"github.com/spf13/cobra"
 	"github.com/twmb/franz-go/pkg/kerr"
 	"github.com/twmb/franz-go/pkg/kmsg"
+	"gopkg.in/yaml.v3"
 )
 
 func NewCreateCommand(fs afero.Fs) *cobra.Command {
@@ -53,7 +54,9 @@ the cleanup.policy=compact config option set.
 			p := config.ParamsFromCommand(cmd)
 			cfg, err := p.Load(fs)
 			out.MaybeDie(err, "unable to load config: %v", err)
-
+			fmt.Println("Config in Topic Create: ")
+			marshal, _ := yaml.Marshal(cfg)
+			fmt.Println(string(marshal))
 			cl, err := kafka.NewFranzClient(fs, p, cfg)
 			out.MaybeDie(err, "unable to initialize kafka client: %v", err)
 			defer cl.Close()