选择使用Kafka是因为Kafka作为中间件他的吞吐量比较高 , 我们的系统中主要使用Kafka来处理一些用户的行为数据 , 用户行为数据用户操作成本低 , 数据量比较大 , 需要有更高的吞吐量支持 , 并且我们在项目中需要实现根据用户行为的实时推荐 , 运营端后台管理系统首页看板数据的实体展示 !
使用Kafka有很多好处：
● 吞吐量提升：无需等待订阅者处理完成，响应更快速
● 故障隔离：服务没有直接调用，不存在级联失败问题
● 调用间没有阻塞，不会造成无效的资源占用
● 耦合度极低，每个服务都可以灵活插拔，可替换
● 流量削峰：不管发布事件的流量波动多大，都由Broker接收，订阅者可以按照自己的速度去处理事件
使用Kafka也有很多缺点：
● 架构复杂了，业务没有明显的流程线，不好管理
● 需要依赖于Broker的可靠、安全、性能
