Kafka消息可靠性配置

Kafka發送消息是異步的，所以若是沒有設置異步回調異常處理，很容易致使消息丟失並且系統不知道的狀況的。 所以咱們在業務有須要的狀況下，配置好消息的可靠性參數。 主要配置如下參數html max.block.ms = acks = all or -1 retries = Integer.MAX_VALUE max.in.flight.requests.per.connection = 1 uncl

>>阅读原文<<