对接核心流水方案

1.需求

在对接流水的时候，通常会对实时性和准确性有要求，但是核心在流式下发流水的时候又难免会造成冗余流水记录，例如:修改了某笔流水或删除了某笔流水，这时候，如果下游已经根据流水号完成了对应的业务处理，就很难再撤回。

2.方案设计

既要兼顾实时性，又要兼顾准确性，这里可以让上游核心实时推送到kafka，我们来进行实时消费，消费完之后根据业务逻辑进行加工处理，把结果进行首次落库，这个结果用于给业务实时查询使用，这里的数据条数可能不准确，会多一些。等到半夜12点之后，当天的日终数据不会再发生改变，让核心重新推一份，我们再来消费，并把白天落库结果进行删除，然后重新覆盖，这样的话就能保证日终数据的准确性。