kafka

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

type Decoder interface {
	Decode(topic string, data []byte) ([]byte, error)
}

type Message struct {
	Partition Partition `json:"partition"`
	Value     []byte    `json:"msg"`
	Offset    int64     `json:"offset"`
}

type Opt func(*Client)

type Partition struct {
	Topic     string `json:"topic"`
	Partition int32  `json:"partition"`
	Start     int64  `json:"start"`
	End       int64  `json:"end"`
	Offset    int64  `json:"offset"`
	Filter    string `json:"filter"`
}