Kafka生产者重试
分类:
文章
•
2024-04-24 15:36:57
基本原理
源码
- handleTimedOutRequests 调用processDisconnection，调用 this.inFlightRequests.clearAll(nodeId)，将超时的清除，并返回超时数据。 responses：List。
- completeResponses(responses);
completeBatch（）
reenqueueBatch(batch,now); 重新排队
deque.addFirst(batch);
