消息中心分发

重试或异常，入库告警人为处理

2. 保障事件数据不丢失kafka 在broker 挂掉，如果数据没有同步到follower就会导致数据丢失；解决办法：通过调整kafka 的参数可以确保数据不会丢失；replication.factor设置为2；min.insync.replicas设置为2；ack设置为-1；消费端弄丢了数据：用手动提交的方式来解决，当数据处理成功后再提交offset

HTTP

事件发送

3. 保障事件不重复producer和consumer 通过唯一标示 去重

事件发送记录

ack（-1）+retries

弹性伸缩服务ESS

rabbit mq集群

接口转发

Producer

事件消费

负载均衡SLB

token验证

kafka 集群

rocket mq集群

事件消费记录

mysql

手动提交offset

Consumer