kafka

func NewkafkaWriter ¶

func NewkafkaWriter(config *models.Config, logger *zap.Logger) (sinks.Sink, error)

NewKafaWriter FIXME support more config options `config` contains

{
	"kafka_brokers": "<ip:port;ip:port;...>",
	"kafka_topic": "<my_topic>",
 "require_acks": "<true>|<false>",
 "flush_memory": "<true>|<false>",
 "write_mode": "<sync>|<async>",
}