kafka

type Config struct {
	Addrs   []string `mapstructure:"addrs"`
	Version string   `mapstructure:"version"` // 3.4.0
	Topic   string   `mapstructure:"topic"`

	// consumer
	GroupId string `mapstructure:"group_id"` // default

	// producer
	Key string `mapstructure:"key"`
}

type Handle func(msg *sarama.ConsumerMessage)

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

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