Versions in this module Expand all Collapse all v0 v0.10.1 Jan 27, 2016 v0.10.0 Jan 9, 2016 Changes in this version + type Kafka struct + Consumer *consumergroup.ConsumerGroup + ConsumerGroup string + Offset string + PointBuffer int + Topics []string + ZookeeperPeers []string + func (k *Kafka) Description() string + func (k *Kafka) Gather(acc inputs.Accumulator) error + func (k *Kafka) SampleConfig() string + func (k *Kafka) Start() error + func (k *Kafka) Stop()
Go to main page