Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2017 Changes in this version + func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error) + type Kafkabeat struct + func (bt *Kafkabeat) Run(b *beat.Beat) error + func (bt *Kafkabeat) Stop()