Message oriented middleware cluster synchronization

An apparatus comprising:

• a processing device operatively coupled to a memory and configured to:
• collect message-oriented-middleware system parameters from a plurality of message-oriented-middleware clusters;
• analyze the message-oriented-middleware system parameters using one or more machine learning algorithms;
• predict, based at least in part on the analyzing, at least one anomaly in a message-oriented-middleware cluster of the plurality of message-oriented-middleware clusters;
• collect message metadata from the message-oriented-middleware cluster based, at least in part, on the predicting;
• transmit at least part of the message metadata to one or more remaining ones of the plurality of message-oriented-middleware clusters;
• wherein the part of the message metadata corresponds to messaging operations to be transferred from the message-oriented-middleware cluster to the one or more remaining ones of the plurality of message-oriented-middleware clusters, and wherein the part of the message metadata comprises one or more details about progress of message transmission in the message-oriented-middleware cluster, the one or more details including at least one of message offset information and one or more timestamps for messages committed to transmission by the message-oriented-middleware cluster;
• and
• synchronize, based at least in part on the one or more details about the progress of the message transmission, the messaging operations between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters to prevent message duplication between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters;
• wherein, in synchronizing, the processing device is configured to translate the message metadata from a format of a first message-oriented-middleware system to a format of a second message-oriented-middleware system to permit the second message-oriented-middleware system to process the one or more details about the progress of the message transmission and prevent re-transmission of the messages committed to transmission by the message-oriented-middleware cluster.

An article of manufacture comprising a non-transitory processor-readable storage medium having stored therein program code of one or more software programs, wherein the program code when executed by at least one processing device causes said at least one processing device to perform the steps of:

• collecting message-oriented-middleware system parameters from a plurality of message-oriented-middleware clusters;
• analyzing the message-oriented-middleware system parameters using one or more machine learning algorithms;
• predicting, based at least in part on the analyzing, at least one anomaly in a message-oriented-middleware cluster of the plurality of message-oriented-middleware clusters;
• collecting message metadata from the message-oriented-middleware cluster based, at least in part, on the predicting;
• transmitting at least part of the message metadata to one or more remaining ones of the plurality of message-oriented-middleware clusters;
• wherein the part of the message metadata corresponds to messaging operations to be transferred from the message-oriented-middleware cluster to the one or more remaining ones of the plurality of message-oriented-middleware clusters, and wherein the part of the message metadata comprises one or more details about progress of message transmission in the message-oriented-middleware cluster, the one or more details including at least one of message offset information and one or more timestamps for messages committed to transmission by the message-oriented-middleware cluster;
• and
• synchronizing, based at least in part on the one or more details about the progress of the message transmission, the messaging operations between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters to prevent message duplication between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters;
• wherein, in synchronizing, the program code causes said at least one processing device to translate the message metadata from a format of a first message-oriented-middleware system to a format of a second message-oriented-middleware system to permit the second message-oriented-middleware system to process the one or more details about the progress of the message transmission and prevent re-transmission of the messages committed to transmission by the message-oriented-middleware cluster.