util

func ExitOnErr ¶

func ExitOnErr(err error)

func NewConfig ¶

func NewConfig(user, pw, apiKey string) (*sarama.Config, error)

func PopulateConfig ¶

func PopulateConfig(config *sarama.Config, user, pw, apiKey string) error

func RequiredEnvVar ¶

func RequiredEnvVar(name, defaultVal string) string

RequiredEnvVar gets an env var value. If a default value is not supplied and the env var is not defined, a fatal error is displayed.

func TlsConfig ¶

func TlsConfig(certFile, keyFile string) (*tls.Config, error)

func Verbose ¶

func Verbose(msg string, args ...interface{})