問題描述A項(xiàng)目中有一個(gè)方法，先將數(shù)據(jù)保存在mysql中，然后將mysql的插入操作返回?cái)?shù)據(jù)的id作為消息體，通過kafka發(fā)送。(此方法已被@Transactional，所以插入數(shù)據(jù)和發(fā)送消息應(yīng)該會(huì))B項(xiàng)目收到消息后，從MySQL中查詢消息的詳情，并進(jìn)行后續(xù)操作。線上部署時(shí)，mysql是遠(yuǎn)程的數(shù)據(jù)庫服務(wù)器，而kafka，A項(xiàng)目，B項(xiàng)目部署在同一臺(tái)服務(wù)器。出現(xiàn)一個(gè)問題就是，A發(fā)送的消息，B項(xiàng)目已經(jīng)接收，并開始根據(jù)消息中的id查詢數(shù)據(jù)庫，但是此時(shí)，數(shù)據(jù)庫的插入操作還未完成，導(dǎo)致查詢結(jié)果為空。這種情況下，如何對(duì)數(shù)據(jù)庫插入操作和kafka發(fā)送消息進(jìn)行控制，確保，B收到消息時(shí)，數(shù)據(jù)庫插入操作已經(jīng)完成，并且當(dāng)kafka消息發(fā)送失敗時(shí)，能夠正確的回退操作。目前，我的做法是進(jìn)行手動(dòng)控制，去掉@Transactional注解，當(dāng)消息發(fā)送出現(xiàn)異常時(shí)，手動(dòng)對(duì)之前的數(shù)據(jù)庫插入操作新增的數(shù)據(jù)進(jìn)行刪除。有沒有更優(yōu)雅的解決方案？