kaƒkaconsumer

Documentation

Index

• type Consumer
  • func New(ctx context.Context, config *sarama.Config, ...) (*Consumer, error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Consume(ctx context.Context, topics []string) <-chan *kafkaconsumermessage.Message

Types

type Consumer

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

func New

func New(
	ctx context.Context,
	config *sarama.Config,
	kafkaCfg kafkaconfiginterface.Configurator,
	lgr logger.Logger,
) (*Consumer, error)

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Consume

func (c *Consumer) Consume(ctx context.Context, topics []string) <-chan *kafkaconsumermessage.Message