ka

type Config struct {
	// broker的集群地址
	Brokers   []string          `toml:"brokers"`
	Consumers []*ConsumerConfig `toml:"consumers"`
}

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

type ConsumerConfig struct {
	// broker的集群地址
	Brokers []string `toml:"brokers"`
	// topic 的名称
	Topic string `toml:"topic"`
	// 消费组名称
	Group string `toml:"group"`
	SASL  struct {
		Enable   bool   `toml:"enable"`
		User     string `toml:"user"`
		Password string `toml:"password"`
	} `toml:"sasl"`
	// 多少个协程
	Workers int `toml:"workers"`
	// 是否从最老的开始消费
	Oldest bool `toml:"oldest"`
}

type Event struct {
	Time     string          `json:"Time,omitempty"`
	Hostname string          `json:"Hostname,omitempty"`
	From     string          `json:"From,omitempty"`
	Type     string          `json:"Type,omitempty"`
	Data     json.RawMessage `json:"Data,omitempty"`
}

type HandleConsumerFunc func(e *Event) error

type HandleConsumerMsgFunc func(message *sarama.ConsumerMessage)

type HandleErrorFunc func(error)

type HandleSucceedFunc func(*sarama.ProducerMessage)

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

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