Kafka生产者重试

基本原理

源码

1. handleTimedOutRequests 调用processDisconnection，调用 this.inFlightRequests.clearAll(nodeId)，将超时的清除，并返回超时数据。 responses：List。
2. completeResponses(responses);
       completeBatch（）
           reenqueueBatch(batch,now); 重新排队
                 deque.addFirst(batch);