Versions in this module Expand all Collapse all v0 v0.2.0 Oct 26, 2015 v0.1.9 Sep 22, 2015 Changes in this version type Kafka + RoutingTag string v0.1.8 Sep 4, 2015 v0.1.7 Aug 27, 2015 Changes in this version + type Kafka struct + Brokers []string + Topic string + func (k *Kafka) Close() error + func (k *Kafka) Connect() error + func (k *Kafka) Description() string + func (k *Kafka) SampleConfig() string + func (k *Kafka) Write(bp client.BatchPoints) error
Go to main page