INNER CODE UNIT · Go

NewKafkactlCommand

deviceinsight/kafkactl · cmd/root.go:27

func NewKafkactlCommand(streams output.IOStreams) *cobra.Command {

	var rootCmd = &cobra.Command{
		Use:           "kafkactl",
		Short:         "command-line interface for Apache Kafka",
		Long:          `A command-line interface the simplifies interaction with Kafka.`,
		SilenceUsage:  true,
		SilenceErrors: true,
	}

	globalConfig := global.NewConfig()

	cobra.OnInitialize(func() {
		if err := globalConfig.Init(); err != nil {
			output.Warnf("failed to initialize config: %v", err)
			os.Exit(1)
		}
	})

View source record →