kafka

Documentation

Index

• func NewKafkaDataWriter(brokerConfig base.BaseConfig) base.DataWriter
• type KafkaDataWriter
  • func (writer *KafkaDataWriter) Start()
  • func (writer *KafkaDataWriter) Stop()
  • func (writer *KafkaDataWriter) WriteData(data *base.Data) error
  • func (writer *KafkaDataWriter) WriteDataAsync(data *base.Data) error
  • func (writer *KafkaDataWriter) WriteDataSync(data *base.Data) error

Functions

func NewKafkaDataWriter

func NewKafkaDataWriter(brokerConfig base.BaseConfig) base.DataWriter

Types

type KafkaDataWriter

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

func (*KafkaDataWriter) Start

func (writer *KafkaDataWriter) Start()

func (*KafkaDataWriter) Stop

func (writer *KafkaDataWriter) Stop()

func (*KafkaDataWriter) WriteData

func (writer *KafkaDataWriter) WriteData(data *base.Data) error

func (*KafkaDataWriter) WriteDataAsync

func (writer *KafkaDataWriter) WriteDataAsync(data *base.Data) error

func (*KafkaDataWriter) WriteDataSync

func (writer *KafkaDataWriter) WriteDataSync(data *base.Data) error