kafka

type ByteDecoder struct{}

type ByteEncoder struct{}

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

type DecoderFunc func(value []byte) (interface{}, error)

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

type EncoderFunc func(interface{}) ([]byte, error)

type Metadata []*PartitionOffset

type PartitionOffset struct {
	Origin streams.MetadataOrigin

	Topic     string
	Partition int32
	Offset    int64
}

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
	ErrorsBufferSize int
}

type StringDecoder struct{}

type StringEncoder struct{}