队列保证消息不丢失
1.生产者:使用trycatch捕获错误,不断重连,如果多次失败后发出警告和做好日志记录
2.存储消息:broker进行集群部署,有多副本机制,将消息写入所有broker,等所有broker写完后再相应给生产者
3.消费消息:当消费者真正执行完业务逻辑之后,再发送给broker消费成功
如何处理重复消息
1.重复消息出现的情况有两种:一生产者发消息,网络发生问题,broker响应时生产者没有收到,再发一次;二消费者消费消息时,consumer offset没有更新,消费者挂了;
2.处理方法:幂等处理重复消息,一版本控制;二数据库的约束例如唯一键;三记录关键的key



