Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func TransformMessage ¶
func TransformMessage(msg *sarama.ConsumerMessage) *kafka.Message
Types ¶
type ConsumerGroupHandler ¶
type ConsumerGroupHandler struct {
// contains filtered or unexported fields
}
func NewConsumerGroupHandler ¶
func NewConsumerGroupHandler(handler kafka.Handler, opts ...ConsumerGroupHandlerOption) (*ConsumerGroupHandler, error)
func (*ConsumerGroupHandler) Cleanup ¶
func (h *ConsumerGroupHandler) Cleanup(_ sarama.ConsumerGroupSession) error
func (*ConsumerGroupHandler) ConsumeClaim ¶
func (h *ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*ConsumerGroupHandler) Setup ¶
func (h *ConsumerGroupHandler) Setup(_ sarama.ConsumerGroupSession) error
type ConsumerGroupHandlerOption ¶
type ConsumerGroupHandlerOption func(*ConsumerGroupHandler)
func ConsumerGroupHandlerErrorHandler ¶
func ConsumerGroupHandlerErrorHandler(errHandler transport.ErrorHandler) ConsumerGroupHandlerOption
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
func NewListener ¶
func NewListener( topics []string, consumerGroup sarama.ConsumerGroup, consumerGroupHandler sarama.ConsumerGroupHandler, opts ...ListenerOption, ) (*Listener, error)
type ListenerOption ¶
type ListenerOption func(*Listener)
func ListenerErrorHandler ¶
func ListenerErrorHandler(errHandler transport.ErrorHandler) ListenerOption
Source Files
Click to show internal directories.
Click to hide internal directories.