kafkaconsumer

type Handler struct {
}

type HandlerFunc struct {
	MessageKey string
	Func       func([]byte) error
}

type IBroker struct {
	Topic     string
	FailTopic string
	KafkaHost []string
}

type IConsumer struct {
	Cnt     int
	GroupId string
}

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

type IKafkaCallback func(broker IBroker, partition int32, offset int64, Key string, Value []byte, ext interface{}) bool

type OptionFunc func(*Options)

type Options struct {
	KafkaHost   string `ini:"kafkahost"`
	Topic       string `ini:"topic"`
	FailTopic   string `ini:"failtopic"`
	ConsumerCnt int    `ini:"consumerCnt"`
	GroupName   string `ini:"groupName"`
}

type Server struct {
	Opts Options
	// contains filtered or unexported fields
}