manager

type Manager interface {
	GetOutboxConfig() config.OutboxConfig
	GetKafkaConfig() config.KafkaConfig
	GetKafkaProducer() *kafka.Producer
	GetDB() *sql.DB
	SetEventHandler(event.EventHandler)
	GetEventHandler() event.EventHandler
	// Insert(*sql.Tx, *model.OutboxRecord) error
	Start() error
	Await()
}