client

type Config ¶

type Config struct {
	InputCh       <-chan *InputArg
	LastCommitSeq uint64
	Logger        Logger
}

type InputArg ¶

type InputArg struct {
	Data   []byte
	Offset int64
}

InputArg holds kafka message data and offset.User send InputArg to the decoder, and the decoder will decode kafka message and return OutputResult to user.

type Logger ¶

type Logger interface {
	Printf(string, ...interface{})
}

Logger is an interface that can be implemented to provide custom log output.

var DefaultLogger Logger = defaultLogger{}

type OperationDecoder ¶

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

func NewOperationDecoder(cfg *Config) (*OperationDecoder, error)

func (o *OperationDecoder) Close() error

func (o *OperationDecoder) Err() <-chan error

func (o *OperationDecoder) Output() <-chan *OutputResult

type OutputResult ¶

type OutputResult struct {
	Ops          []*protocol.Operation
	BeginSeq     uint64
	EndSeq       uint64
	BeginOffset  int64
	EndOffset    int64
	CommitOffset int64
	CommitSeq    uint64
}

OutputResult holds operations decoded from kafka message, seq info, offset info and commit info. Once user has handled/consumed this OutputResult, user can save/commit the commit info. After user restart, user can continue consume kafka from offset at CommitOffset+1.