场景描述： Kafka 中的数据直接入到 MySQL 数据库中，数据格式如下: order_id status 只有两个字段， order_id 为主键，以 replace 覆盖方式写入到数据库中。
对同一个 order_id, status 变化很频繁，为不对数据库造成压力，不会对每一条记录都做入库操作，但一定要保证这个 order_id 最终的状态不丢，但这个最终的状态也不确定是多少。 我的做法是 KeyBy orderId 后判断两条记录的时间间隔，如果时间间隔太小不做入库操作，但如果这个 order_id 最后来的两条记录时间间隔太小，会导致最终的状态丢失。 请问有什么其他的解决方法吗？ 谢谢， 王磊
