现状:应用是负责订单流程管理,同时还要将一些数据实时同步给外围系统,同时需要提供查询和统计报表的功能,这些模块在一起会影响订单的流转,数据库Oracle压力较大。
需求:现在想要将数据同步和查询报表的功能单独作为一个应用,数据采集通过OGG+KAFKA,然后应用读取KAFKA中的消息,(快速解析消息,根据指标和报表的条件来校验数据是否匹配,然后将统计数据存入redis中),对于需要同步给外围系统的数据则通过接口表+OGG形式。
疑问:从Kafka中消费ogg的消息,对消息进行加工处理采用什么技术?将报表统计数据存入redis中是否合理, 大数据对此是否适用。
恳请各位仁兄提供建议。