groupHandler

Documentation

Index

• type AnalysisConsumerGroupHandler
  • func NewAnalysisConsumerGroupHandler(scanner *scanner.Scanner, producer producer.IProducer, ...) *AnalysisConsumerGroupHandler
  • func NewAnalysisConsumerGroupHandlerDefault(scanner *scanner.Scanner, producer producer.IProducer) *AnalysisConsumerGroupHandler
  • func (h *AnalysisConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error
  • func (h *AnalysisConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h *AnalysisConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error

Types

type AnalysisConsumerGroupHandler

type AnalysisConsumerGroupHandler struct {
	// contains filtered or unexported fields
}

func NewAnalysisConsumerGroupHandler

func NewAnalysisConsumerGroupHandler(scanner *scanner.Scanner, producer producer.IProducer, topicResult, topicError string, logService logservice.Logger) *AnalysisConsumerGroupHandler

func NewAnalysisConsumerGroupHandlerDefault

func NewAnalysisConsumerGroupHandlerDefault(scanner *scanner.Scanner, producer producer.IProducer) *AnalysisConsumerGroupHandler

func (*AnalysisConsumerGroupHandler) Cleanup

func (h *AnalysisConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

func (*AnalysisConsumerGroupHandler) ConsumeClaim

func (h *AnalysisConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*AnalysisConsumerGroupHandler) Setup

func (h *AnalysisConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error