Kafka消息可靠性配置

Kafka发送消息是异步的，所以若是没有设置异步回调异常处理，很容易致使消息丢失并且系统不知道的状况的。 所以咱们在业务有须要的状况下，配置好消息的可靠性参数。 主要配置如下参数html max.block.ms = acks = all or -1 retries = Integer.MAX_VALUE max.in.flight.requests.per.connection = 1 uncl

>>阅读原文<<