本申请公开了一种基于消息中间件的数据处理方法及装置，该方法为：将第一集群的生产者所生产的消息，保存到第一集群的目标主题中；基于第一复制器的消费游标，从与目标主题对应的消息队列中获取消息，并将消息保存到第一复制器中；调用第一复制器中的生产者，将第一复制器中的消息发送给第二集群，以使第二集群的目标主题保存消息；在确定第二集群的目标主题成功保存消息后，向第一复制器发送确认字符，以使第一复制器更新消费游标。该方法基于预置在第一集群中(具体内置于broker节点进程内)、且包含第二集群的生产者的第一复制器，可在不消耗第一集群的机器资源的情况下，将第一集群的消息复制到第二集群中，提高集群的容灾能力。