transformer

Documentation

Index

• type Projector
• type Transformer
  • func PassThrough() Transformer

Types

type Projector

type Projector interface {
	Project(message *kafka.Message)
}

Projector is an interface which is used by Kafka.Transformer in order to project a kafka Message (to kafka or an external system) If you want to customize the projection, this is the interface to implement

type Transformer

type Transformer interface {
	Transform(src *kafka.Message) []*kafka.Message
}

Transformer is an interface which is used by Kafka.Transformer in order to transform a kafka Message. If nil is returned the message will be ignored

func PassThrough

func PassThrough() Transformer

PassThrough returns a transformer which does nothing, just transferring the message in a new topic