cmd

var RootCmd = &cobra.Command{
	Use:   "kafka-cli",
	Short: "kafka-cli utility",
	Long: `kafka-cli is a console util tool to access kafka cluster
`,

	PersistentPreRun: func(cmd *cobra.Command, args []string) {
		var err error

		if verbose {
			sarama.Logger = log.New(os.Stderr, "[kafka-cli] ", log.LstdFlags)
		}

		if logAuthMsg {
			fmt.Printf("AuthLog: User: %s, Password: %s, ClientID: %s\n",
				cfg.Net.SASL.User, cfg.Net.SASL.Password, cfg.ClientID)
		}

		addrs := strings.Split(brokers, ",")
		kafkaClient, err = sarama.NewClient(addrs, cfg)
		exitOnError(err)
	},
}