reader

type Config struct {
	KafkaAddr []string
	// the CommitTs of binlog return by reader will bigger than the config CommitTs
	CommitTS int64
	Offset   int64 // start at kafka offset
	// if Topic is empty, use the default name in drainer <ClusterID>_obinlog
	Topic     string
	ClusterID string
}

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

type Message struct {
	Binlog *pb.Binlog
	Offset int64 // kafka offset
}

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