kafka1

package module

v0.0.1 Latest Latest Go to latest Published: Aug 19, 2019 License: Apache-2.0 Imports: 6 Imported by: 8

Details

This section is empty.

This section is empty.

This section is empty.

type ConfigMap map[string]interface{}

type ConsumerCheckpoint struct {
	Partition int32
	Offset    uint64
}

func (c ConsumerCheckpoint) String() string

type Sink struct {
	Topic          string
	ProducerConfig ConfigMap
}

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 {
	Topic          string
	ConsumerConfig ConfigMap
}

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)