Versions in this module Expand all Collapse all v0 v0.0.1 Aug 19, 2019 Changes in this version + type ConfigMap map[string]interface + type ConsumerCheckpoint struct + Offset uint64 + Partition int32 + func (c ConsumerCheckpoint) String() string + type Sink struct + ProducerConfig ConfigMap + Topic string + func (sink *Sink) Close(ctx *goconnect.Context) error + func (sink *Sink) Flush(ctx *goconnect.Context) error + func (sink *Sink) InType() reflect.Type + func (sink *Sink) Process(input *goconnect.Element, ctx *goconnect.Context) + type Source struct + ConsumerConfig ConfigMap + Topic string + func (source *Source) Close(ctx *goconnect.Context) error + func (source *Source) Commit(checkpoint goconnect.Watermark, ctx *goconnect.Context) error + func (source *Source) OutType() reflect.Type + func (source *Source) Run(context *goconnect.Context)