service

type Service struct {
	Consumer           *consumer.GroupConsumer
	Producer           *producer.Producer
	PpSchema           string
	Client             *http.Client
	InitialOffset      int64
	HandleError        func(err error, offset int64, str interface{}) error
	Topic              string
	Retry              *resilience.ServiceRetry
	IsErrorConsumer    bool
	BrokerAddr         []string
	APIKey             string
	PaymentsAPIURL     string
	DAO                dao.DAO
	TranCollection     string
	ProdCollection     string
	ProductMap         *config.ProductMap
	Payments           payment.Fetcher
	Transformer        transformer.Transformer
	StopAtOffset       int64
	SkipGoneResource   bool
	SkipGoneResourceId string
}