kafka

type ByteDecoder struct{}

type ByteEncoder struct{}

type Decoder interface {
	// Decode transforms byte data to the desired type.
	Decode([]byte) (interface{}, error)
}

type Encoder interface {
	// Encode transforms the typed data to bytes.
	Encode(interface{}) ([]byte, error)
}

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

type SinkConfig struct {
	sarama.Config

	Brokers []string
	Topic   string

	KeyEncoder   Encoder
	ValueEncoder Encoder

	BatchSize int
}

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

type SourceConfig struct {
	sarama.Config

	Brokers []string
	Topic   string
	GroupId string

	Ctx          context.Context
	KeyDecoder   Decoder
	ValueDecoder Decoder

	BufferSize int
}

type StringDecoder struct{}

type StringEncoder struct{}