kafka

Documentation

Index

• type AsyncSinkFactory
  • func (f AsyncSinkFactory) NewAsyncSink(ctx context.Context, req *proto.StartPublishRequest) (substrate.AsyncMessageSink, error)
• type AsyncSourceFactory
  • func (f AsyncSourceFactory) NewAsyncSource(ctx context.Context, req *proto.StartConsumeRequest) (substrate.AsyncMessageSource, error)

Types

type AsyncSinkFactory

type AsyncSinkFactory struct {
	Brokers         []string
	Version         string
	MaxMessageBytes int
	KeyFunc         func(substrate.Message) []byte
	Debug           bool
}

func (AsyncSinkFactory) NewAsyncSink

func (f AsyncSinkFactory) NewAsyncSink(ctx context.Context, req *proto.StartPublishRequest) (substrate.AsyncMessageSink, error)

type AsyncSourceFactory

type AsyncSourceFactory struct {
	Brokers                  []string
	Version                  string
	OffsetsRetention         time.Duration
	MetadataRefreshFrequency time.Duration
	SessionTimeout           time.Duration
	Debug                    bool
}

func (AsyncSourceFactory) NewAsyncSource

func (f AsyncSourceFactory) NewAsyncSource(ctx context.Context, req *proto.StartConsumeRequest) (substrate.AsyncMessageSource, error)