kafka

Documentation

Index

• type Consumer
  • func NewConsumer(creator repository.Creator, tracer tracing.Tracer) (Consumer, error)
  • func (c Consumer) Cleanup(sarama.ConsumerGroupSession) error
  • func (c Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (c Consumer) ReceivedMessage(message *sarama.ConsumerMessage) error
  • func (c Consumer) Setup(sarama.ConsumerGroupSession) error

Types

type Consumer

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

Consumer represent a kafka transport consumer.

func NewConsumer

func NewConsumer(creator repository.Creator, tracer tracing.Tracer) (Consumer, error)

NewConsumer returns a new consumer.

func (Consumer) Cleanup

func (c Consumer) Cleanup(sarama.ConsumerGroupSession) error

func (Consumer) ConsumeClaim

func (c Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (Consumer) ReceivedMessage

func (c Consumer) ReceivedMessage(message *sarama.ConsumerMessage) error

ReceivedMessage contains logic for creating a todo.

func (Consumer) Setup

func (c Consumer) Setup(sarama.ConsumerGroupSession) error