source

type Kafka struct {
	Version string   `yaml:"version"`
	Brokers []string `yaml:"brokers"`
	Topics  []string `yaml:"topics"`
	Group   string   `yaml:"group"`

	Assignor string `yaml:"assignor"`
	Newest   bool   `yaml:"newest"`

	OutC chan interface{} `yaml:"-"`
}

type Mysql struct {
	DSN           string   `yaml:"dsn"`
	BinPosition   string   `yaml:"binPosition"`
	Tables        []string `yaml:"tables"`
	SyncMarkTable string   `yaml:"syncMarkTable"`
	SyncChannel   string   `yaml:"syncChannel"`

	OutC chan interface{} `yaml:"-"`
}

type Noop struct {
	OutC chan interface{} `yaml:"-"`
}