3.6 Kafka Producer API之消息傳遞保障

1.傳遞保障

在一個分布式釋出訂閱消息系統中，組成系統的計算機總會由于各自的故障而不能正常工作。在Kafka中，一個單獨的broker，可能會在生産者發送消息到一個topic的時候當機，或出現網絡故障，進而導緻生産者發送消息失敗。

kafka提供了三種傳遞保障來解決上述問題，其依賴producer和consumer共同實作，主要依賴producer，在代碼中由“properties.put(ProducerConfig.ACKS_CONFIG, “all”);”展現，配置的值有以下三種情況(server完成producer request前需要确認的數量)。

(1).0

最多一次，收到0或者1次消息，消息發出後，不會等待任何響應，無法保證消息是否成功發送到broker中。producer不會等待确認，直接添加到socket等待發送。