消息队列 Kafka（公测中）

金融企业进行用户风险管理时，需要对客户贷款过程进行风险预警。以前的做法是客户贷款后，再对客户数据统一收集和分析客户风险情况。由于数据量大，收集数据和分析风险的时效性差，时间成本高。使用消息队列Kafka，基于流式处理后，在客户贷款信息录入时，对该信息进行计算分析，并且准实时得到客户贷款风险情况。通过快速获知客户贷款的风险，能实时判断是否进行此次贷款业务。

在企业销售流程中，用户下单后，订单系统告知库存系统出库。传统的直接调用方式，若库存系统无法访问，则订单减库存会失败，从而导致订单失败，影响交易效率。将订单系统和库存系统分别接入Kafka，用户下单后，订单系统将消息写入Kafka，完成持久化处理；库存系统订阅获取下单信息，进行库存操作。实现了生产者和消费者之间的应用解耦，提升交易效率。