sink

Documentation

Index

• type KafkaSinkHandler
  • func NewKafkaSinkHandler(baseSink sink.BaseSink, sinkKafkaCfg config.KafkaSinkConfig) *KafkaSinkHandler
  • func (k *KafkaSinkHandler) CloseSink()
  • func (k *KafkaSinkHandler) InitSink()
  • func (k *KafkaSinkHandler) SinkName() string
  • func (k *KafkaSinkHandler) WriteData()

Types

type KafkaSinkHandler

type KafkaSinkHandler struct {
	sink.BaseSink
	// contains filtered or unexported fields
}

func NewKafkaSinkHandler

func NewKafkaSinkHandler(baseSink sink.BaseSink, sinkKafkaCfg config.KafkaSinkConfig) *KafkaSinkHandler

NewKafkaSinkHandler creates a new Kafka sink handler

func (*KafkaSinkHandler) CloseSink

func (k *KafkaSinkHandler) CloseSink()

CloseSink closes the Kafka sink

func (*KafkaSinkHandler) InitSink

func (k *KafkaSinkHandler) InitSink()

InitSink initializes the Kafka sink

func (*KafkaSinkHandler) SinkName

func (k *KafkaSinkHandler) SinkName() string

SinkName returns the name of the Kafka sink

func (*KafkaSinkHandler) WriteData

func (k *KafkaSinkHandler) WriteData()

WriteData writes data to Kafka