生产者丢失消息的情况
不要使用 producer.send(msg)，而要使用 producer.send(msg, callback)。
retries(重试)设置一个较大的值，一般是 3； 注意建议还要设置重试间隔
消费者丢失消息的情况
手动关闭闭自动提交 offset，每次在真正消费完消息之后之后再自己手动提交 offset 。
存在重复消费问题
Kafka 丢失消息的情况
设置 acks = all
设置 replication.factor >= 3
设置 min.insync.replicas > 1<br>
设置 unclean.leader.election.enable = false
