Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
func NewConsumer(addr []string, topics []string, consumerGroupID string, handler sarama.ConsumerGroupHandler, opts ConsumerOptions) (*Consumer, error)
type ConsumerOptions ¶ added in v0.0.6
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler is a convenience struct for creating a sarama.ConsumerGroupHandler
func NewHandler ¶
func NewHandler(messageReceived func(payload []byte) error, opts ...HandlerOptions) *Handler
func (*Handler) ConsumeClaim ¶
func (h *Handler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
type HandlerOptions ¶ added in v0.0.3
type HandlerOptions struct { Setup func(sess sarama.ConsumerGroupSession) error Cleanup func(sess sarama.ConsumerGroupSession) error }
Click to show internal directories.
Click to hide internal directories.