kafkamessagehandlerinterface

Documentation

Index

• type ConsumerGroupHandler

Types

type ConsumerGroupHandler

type ConsumerGroupHandler interface {
	sarama.ConsumerGroupHandler
	// Messages returns messages chan.
	Messages() <-chan *kafkaconsumermessage.Message
	Close()
}