kafka

README

Apache Kafka

Documentation

Index

• func New(logger log.Logger) plugins.Syncer
• type Config
• type ProtoReflector
• type Sink
  • func (s *Sink) Close() (err error)
  • func (s *Sink) Init(ctx context.Context, config plugins.Config) error
  • func (s *Sink) Sink(ctx context.Context, batch []models.Record) error

Functions

func New

func New(logger log.Logger) plugins.Syncer

Types

type Config

type Config struct {
	Brokers string `mapstructure:"brokers" validate:"required"`
	Topic   string `mapstructure:"topic" validate:"required"`
	KeyPath string `mapstructure:"key_path"`
}

type ProtoReflector

type ProtoReflector interface {
	ProtoReflect() protoreflect.Message
}

type Sink

type Sink struct {
	plugins.BasePlugin
	// contains filtered or unexported fields
}

func (*Sink) Close

func (s *Sink) Close() (err error)

func (*Sink) Init

func (s *Sink) Init(ctx context.Context, config plugins.Config) error

func (*Sink) Sink

func (s *Sink) Sink(ctx context.Context, batch []models.Record) error