kafka

Documentation

Index

• type Kafka
  • func New(ctx context.Context, cfg kafkaconfiginterface.Configurator, lgr logger.Logger, ...) (kafka *Kafka, err error)
  • func (k *Kafka) Close() error

Types

type Kafka

type Kafka struct {
	kafkaconsumerinterface.Consumer
	kafkaproducerinterface.Producer
	// contains filtered or unexported fields
}

func New

func New(
	ctx context.Context,
	cfg kafkaconfiginterface.Configurator,
	lgr logger.Logger,
	errorHandler kafkaasyncproducerhandler.ErrorHandler,
	successHandler kafkaasyncproducerhandler.SuccessHandler,
	certsFS ...embed.FS,
) (kafka *Kafka, err error)

New method creates a new Kafka instance.

param: errorHandler   - is optional callback which used with async provider.
param: successHandler - is optional callback which used with async provider.

func (*Kafka) Close

func (k *Kafka) Close() error