kafka

type Conf struct {
	Brokers    []string
	Group      string
	Topic      string
	Offset     string `json:",options=first|last,default=last"`
	Conns      int    `json:",default=1"`
	Consumers  int    `json:",default=8"`
	Processors int    `json:",default=8"`
	MinBytes   int    `json:",default=10240"`    // 10K
	MaxBytes   int    `json:",default=10485760"` // 10M
}

type HeaderKey struct{}

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

type PushOption func(options *pushOptions)

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

type QueueOption func(*queueOptions)

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