kafka

type Configuration struct {
	URL            string `conf:"default=localhost"`
	Port           string `conf:"default=9093"`
	Events         string `conf:"default=events"`
	Items          string `conf:"default=items"`
	KeepAlive      int    `conf:"range=60:300,default=300"`
	Username       string `conf:"optional"`
	Password       string `conf:"optional"`
	CaFile         string `conf:"optional"`
	ClientCertFile string `conf:"optional"`
	ClientKeyFile  string `conf:"optional"`
	Retry          int    `conf:"default=0"`
	Timeout        int    `conf:"default=1"`
	TLSAuth        bool   `conf:"default=false"`
	EnableTLS      bool   `conf:"optional"`
}

type DefaultProducer struct {
	// contains filtered or unexported fields
}

type Producer interface {
	ProduceItem(key, message string)
	ProduceEvent(key, message string)
	Close() error
}