Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigLogger ¶
Types ¶
type ConsumerHandler ¶
type ConsumerHandler struct { ReadBufferChan chan *Event // contains filtered or unexported fields }
Consumer represents a Sarama consumer group consumer
func (*ConsumerHandler) Cleanup ¶
func (consumer *ConsumerHandler) Cleanup(sarama.ConsumerGroupSession) error
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
func (*ConsumerHandler) ConsumeClaim ¶
func (consumer *ConsumerHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().
func (*ConsumerHandler) Setup ¶
func (consumer *ConsumerHandler) Setup(sarama.ConsumerGroupSession) error
Setup is run at the beginning of a new session, before ConsumeClaim
type Event ¶
type Event struct { Session sarama.ConsumerGroupSession Msg *sarama.ConsumerMessage }
type KafkaGroupReader ¶
type KafkaGroupReader struct { Consume sarama.ConsumerGroup Consumer ConsumerHandler // contains filtered or unexported fields }
func NewKafkaReader ¶
func (*KafkaGroupReader) Close ¶
func (r *KafkaGroupReader) Close()
func (*KafkaGroupReader) Lag ¶
func (r *KafkaGroupReader) Lag() map[string]int64
func (*KafkaGroupReader) ReadLine ¶
func (r *KafkaGroupReader) ReadLine() *Event
Click to show internal directories.
Click to hide internal directories.