Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExampleConsumerGroupHandler ¶
type ExampleConsumerGroupHandler struct {
// contains filtered or unexported fields
}
func NewConsumerGroupHandler ¶
func NewConsumerGroupHandler() ExampleConsumerGroupHandler
func (ExampleConsumerGroupHandler) Cleanup ¶
func (ExampleConsumerGroupHandler) Cleanup(_ sarama.ConsumerGroupSession) error
func (ExampleConsumerGroupHandler) ConsumeClaim ¶
func (h ExampleConsumerGroupHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (ExampleConsumerGroupHandler) Setup ¶
func (ExampleConsumerGroupHandler) Setup(_ sarama.ConsumerGroupSession) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.