如何保證kafka消息不丟失

背景   這裏的kafka值得是broker,broker消息丟失的邊界需要對齊一下： 1 已經提交的消息 2 有限度的持久化 如果消息沒提交成功，並不是broke丟失了消息； 有限度的持久化（broker可用） 生產者丟失消息 producer.send(Object msg) ;  這個發送消息的方式是異步的；fire and forget,發送而不管結果如何； 失敗的原因可能有很多，比如網絡

>>阅读原文<<