kafka

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

type BatchConsumerConf struct {
	CacheCapacity int `json:",optional"`
	Consumers     int `json:",optional"`
	Processors    int `json:",optional"`
}

type BatchConsumerOption func(*batchConsumerOptions)

type ConsumeHandle func(key string, data []byte) error

type ConsumeHandler interface {
	Consume(key string, data []byte) error
}

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

type ConsumerConfig struct {
	Version        string        `json:",optional"`
	Brokers        []string      `json:",optional"`
	Group          string        `json:",optional"`
	Topic          string        `json:",optional"`
	CacheCapacity  int           `json:",optional"`
	ConnectTimeout time.Duration `json:",optional"`
	// contains filtered or unexported fields
}

type IConsumer interface {
	FetchMessage(ctx context.Context) (message *sarama.ConsumerMessage, err error)
	Close() error
}

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

type ProducerConfig struct {
	Version string   `json:",optional"`
	Brokers []string `json:",optional"`
	// contains filtered or unexported fields
}