kafka

Documentation

Index

• Constants
• type Config
• type KafkaSink
  • func (o *KafkaSink) Checkpoint() *ckp.Checkpoint
  • func (o *KafkaSink) Close() error
  • func (o *KafkaSink) Err() <-chan error
  • func (o *KafkaSink) Initialize(ctx context.Context, ckp *ckp.Checkpoint) error
  • func (o *KafkaSink) OnBegin(h *replication.EventHeader) error
  • func (o *KafkaSink) OnCommit(h *replication.EventHeader, progress prog.Progress) error
  • func (o *KafkaSink) OnDDL(h *replication.EventHeader, e *replication.QueryEvent, p prog.Progress) error
  • func (o *KafkaSink) OnGTID(h *replication.EventHeader, e *canal.GtidEvent) error
  • func (o *KafkaSink) OnQuery(h *replication.EventHeader, e *replication.QueryEvent) error
  • func (o *KafkaSink) OnRotate(h *replication.EventHeader, e *replication.RotateEvent) error
  • func (o *KafkaSink) OnRow(h *replication.EventHeader, e *canal.RowsEvent) error
  • func (o *KafkaSink) String() string
• type Operation

Constants

const (
	Compression_NONE = "none"
	Compression_ZLIB = "zlib"
	Compression_GZIP = "gzip"
)

Types

type Config

type Config struct {
	Encoder        string `toml:"encoder"`
	BrokerList     string `toml:"broker_list"`
	Topic          string `toml:"topic"`
	Partition      int32  `toml:"partition"`
	MaxPayloadSize int    `toml:"max_payload_size"`
	Compression    string `toml:"compression"`
}

type KafkaSink

type KafkaSink struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*KafkaSink) Checkpoint

func (o *KafkaSink) Checkpoint() *ckp.Checkpoint

func (*KafkaSink) Close

func (o *KafkaSink) Close() error

func (*KafkaSink) Err

func (o *KafkaSink) Err() <-chan error

func (*KafkaSink) Initialize

func (o *KafkaSink) Initialize(ctx context.Context, ckp *ckp.Checkpoint) error

func (*KafkaSink) OnBegin

func (o *KafkaSink) OnBegin(h *replication.EventHeader) error

func (*KafkaSink) OnCommit

func (o *KafkaSink) OnCommit(h *replication.EventHeader, progress prog.Progress) error

func (*KafkaSink) OnDDL

func (o *KafkaSink) OnDDL(h *replication.EventHeader, e *replication.QueryEvent, p prog.Progress) error

func (*KafkaSink) OnGTID

func (o *KafkaSink) OnGTID(h *replication.EventHeader, e *canal.GtidEvent) error

func (*KafkaSink) OnQuery

func (o *KafkaSink) OnQuery(h *replication.EventHeader, e *replication.QueryEvent) error

func (*KafkaSink) OnRotate

func (o *KafkaSink) OnRotate(h *replication.EventHeader, e *replication.RotateEvent) error

func (*KafkaSink) OnRow

func (o *KafkaSink) OnRow(h *replication.EventHeader, e *canal.RowsEvent) error

func (*KafkaSink) String

func (o *KafkaSink) String() string

type Operation

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