实时数仓与规则引擎集成：基于Kafka的消息传递

实时数仓会将数据通过消息队列Kafka发送到实时规则引擎模块。规则引擎模块接收数据后会进行自己的业务逻辑计算。交易数据由风控网关采集后发送至Kafka，数据仓库接收Kafka上的数据并将其转换为内部协议对象，然后转发给规则引擎。规则引擎处理的消息包括：委托请求、撤单请求、订单确认和成交回报。数据仓库接收风控网关发送至Kafka的数据，将其转换为内部协议对象，并转发给规则引擎。风控网关处理的消息包括现货快照行情、期权快照行情、盘后固定价快照行情、债券快照行情、现货逐笔成交和债券逐笔成交。