diff --git a/src/go/rpk/pkg/cli/cmd/topic/create.go b/src/go/rpk/pkg/cli/cmd/topic/create.go index 6f4ba6d743013..05af7673169f2 100644 --- 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.Printf(string(marshal)) cl, err := kafka.NewFranzClient(fs, p, cfg) out.MaybeDie(err, "unable to initialize kafka client: %v", err) defer cl.Close()