consumer

type Config struct {
	common.LoggerConfig
	common.ClientConfig
	ProjectID                      string
	TopicIDList                    []string
	ConsumerGroupName              string
	ConsumerName                   string
	ConsumeFrom                    string
	HeartbeatIntervalInSecond      int
	DataFetchIntervalInMillisecond int64
	FlushCheckpointIntervalSecond  int
	MaxFetchLogGroupCount          int
	OrderedConsume                 bool
}

type Consumer interface {
	ResetAccessKeyToken(accessKeyID, accessKeySecret, securityToken string)
	Start() error
	Stop()
}