我使用最新的Kafka版本（0.10.1.1）这里是我Kafka配置的一部分：

props.put("acks", "all");
    props.put("retries", Integer.MAX_VALUE);

我只是不想中止任何消息，但当我关闭网络一段时间，然后重新连接时，Kafka不重试，我按照代码查找：
recordbatch.maybeexpire文件
....

else if (this.inRetry() && requestTimeoutMs < (now - (this.lastAttemptMs + retryBackoffMs))) {
        expire = true;
        errorMessage = (now - (this.lastAttemptMs + retryBackoffMs)) + " ms has passed since last attempt plus backoff time";
    }

这里将中止消息。
我误解了，我该怎么办？是请求超时还是重试回退？