Systems, apparatus, and methods for data integration optimization

A method executed by one or more computing devices for optimizing a plurality of data integration tasks within a data integration collection describing data integration tasks within a data store, the method comprising:

• accessing, using at least one computer processor, a data integration collection describing a plurality of data integration tasks defining a migration of data between at least one source data store and at least one target data store;
• identifying, using at least one computer processor, as a sub-set of the plurality of data integration tasks, a plurality of point-to-point data integration tasks each corresponding to a respective data source and a respective target;
• defining, using the at least one computer processor, a data integration transformation plan to include:
• generating one or more publication data integration tasks comprising publishing from each respective data source of the plurality of point-to-point data integration tasks to generate a single publication topic;
• and
• generating one or more subscription data integration tasks causing each respective target of the plurality of point-to-point data integration tasks to subscribe to the single publication topic;
• and
• generating, using the at least one computer processor, a set of optimization instructions configured to cause the data integration transformation plan.