kafka

type Callback func(message *sarama.ConsumerMessage)

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

type ConsumerGroupConf struct {
	Topic   string   `yaml:"topic"`
	Brokers []string `yaml:"brokers"`
	GroupId string   `yaml:"groupId"`
}

type ProducerConf struct {
	Topic   string   `yaml:"topic"`
	Brokers []string `yaml:"brokers"`
}

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