生产者丢失数据
producer.sens(msg)
不等待确认消息，立即返回
producer.send(msg,callback)
带回调通知的发送API
消费者程序丢失数据
解决方案：维持先消费消息，再更新位移的顺序
重复消费（多线程消费）
Consumer程序不要开启自动提交位移，而是要应用程序手动提交位移
最佳实践
1、不是要使用producer.send(msg),而是用producer.send(msg,callback)
2、设置acks=all。acks是Producer的一个参数，代表了对“已提交”消息的定义，<br>如果设置成all，则表明所有副本Broker都要接收到消息，该消息才是“已提交”。<br>这是最高等级的“已提交”定义
3、设置retries为一个较大的值。这里的retries是Producer的参数，对应Producer自动重试。<br>当出现网络的瞬时抖动时，消息发送可能会失败，此时设置了retries>0的Producer能够自动<br>重试，避免消息丢失。
4、设置unclean.leader.election.enable=false。这是Broker端的参数，它控制的是<br>哪些Broker有资格竞选分区Leader。如果一个Broker落后原先的Leader太多，那么它<br>一旦成为新的Leader，就会造成数据丢失，设置为false是不允许这种情况发生。<br>
5、设置replication.factor>=3。Broker端的参数，标识最好将消息保存几份，<br>毕竟目前防止消息丢失的主要机制就是冗余。
6、设置min.insync.replicas>1。Broker端参数，控制的是消息至少要被写入<br>多少个副本才算“已提交”。设置成大于1可以提升消息持久性。实际环境中<br>千万不要使用默认值1.
7、确保replication.factor>min.insync.replicas。如果两者相等，那么只要其中一个<br>副本挂机，整个分区就无法正常工作了。设置成replication.factor=min.insybc.replicas+1
8、确保消息消费完再提交。Counsumer端有个参数enable.auto.commit，最好把它设置成false，并采用手动提交位移的方式。
