kafkaasyncproducer

Documentation

Index

• type Async
  • func New(ctx context.Context, config *sarama.Config, ...) (*Async, error)
  • func (p *Async) Close() error
  • func (p *Async) Produce(topic, value string) error

Types

type Async

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

func New

func New(
	ctx context.Context,
	config *sarama.Config,
	cfg kafkaconfiginterface.Configurator,
	lgr logger.Logger,
	errorHandler kafkaasyncproducerhandler.ErrorHandler,
	successHandler kafkaasyncproducerhandler.SuccessHandler,
) (*Async, error)

func (*Async) Close

func (p *Async) Close() error

func (*Async) Produce

func (p *Async) Produce(topic, value string) error