consumer

type KafkaCfg struct {
	Broker  []string `yaml:"broker"`
	GroupId string   `yaml:"groupId"`
}

type Scheduler struct {
	BizCtx *biz.SampleBiz
	// contains filtered or unexported fields
}

type Worker struct {
	WorkerConfig
	// contains filtered or unexported fields
}

type WorkerConfig struct {
	KafkaCfg

	Topic       string `yaml:"topic"`
	BufSize     int    `yaml:"bufSize"`
	WorkerCount int    `yaml:"workerCount"`
	// contains filtered or unexported fields
}