kafka

Documentation

Index

• type ToKafka
  • func NewToKafka(ctx context.Context, vertexInstance *dfv1.VertexInstance) (*ToKafka, error)
  • func (tk *ToKafka) Close() error
  • func (tk *ToKafka) GetName() string
  • func (tk *ToKafka) GetPartitionIdx() int32
  • func (tk *ToKafka) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

Types

type ToKafka

type ToKafka struct {
	// contains filtered or unexported fields
}

ToKafka produce the output to a kafka sinks.

func NewToKafka

func NewToKafka(ctx context.Context, vertexInstance *dfv1.VertexInstance) (*ToKafka, error)

NewToKafka returns ToKafka type.

func (*ToKafka) Close

func (tk *ToKafka) Close() error

func (*ToKafka) GetName

func (tk *ToKafka) GetName() string

GetName returns the name.

func (*ToKafka) GetPartitionIdx

func (tk *ToKafka) GetPartitionIdx() int32

GetPartitionIdx returns the partition index. for sink it is always 0.

func (*ToKafka) Write

func (tk *ToKafka) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

Write writes to the kafka topic.