kafka_consumer

Jul 6, 2015

Changes in this version

+ type Kafka struct

+ BatchSize int

+ Consumer *consumergroup.ConsumerGroup

+ ConsumerGroupName string

+ Topic string

+ ZookeeperPeers []string

+ func (k *Kafka) Description() string

+ func (k *Kafka) Gather(acc plugins.Accumulator) error

+ func (k *Kafka) SampleConfig() string

+ type Metric struct

+ Measurement string

+ Tags map[string]string

+ Time time.Time

+ Values map[string]interface{}