kafka

Mar 17, 2017

Changes in this version

+ func NewKafkaSink(uri *url.URL) (event_core.EventSink, error)

+ type KafkaSinkPoint struct

+ EventTags map[string]string

+ EventTimestamp time.Time

+ EventValue interface{}