kafka

type Event func(*sarama.ConsumerMessage)

type KafkaConfig struct {
	Enable           bool     `mapstructure:"enable" json:"enable" yaml:"enable"`                                 // 是否开启
	Partition        int32    `mapstructure:"partition" json:"partition" yaml:"partition"`                        // 分区
	EncoderKey       string   `mapstructure:"encoder-key" json:"encoderKey" yaml:"encoder-key"`                   // 编码key
	BootstrapServers []string `mapstructure:"bootstrap-servers" json:"bootstrapServers" yaml:"bootstrap-servers"` // kafka节点服务器
}

type Msg struct {
	Topic   string
	Message string
}

type Sub struct {
	Topic string
	Event Event
}