Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewkafkaWriter ¶
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>", }
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.