kafkasyncproducer

Documentation

Index

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

Types

type Sync

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

func New

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

func (*Sync) Close

func (p *Sync) Close() error

func (*Sync) Produce

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