Kafka生产者介绍（六）：RecordAccumulator

kafka在发消息的时候回把消息放在缓存中，由sender线程再发送出去，这个缓存就是RecordAccumulator，RecordAccumulator封装了RecordBatch储存消息。主要字段为：node public final class RecordAccumulator { private volatile boolean closed; private fina

>>阅读原文<<