发送消息的时候, 当Broker挂掉了,消息体还能写入到消息缓存中吗?
当消息还存储在缓存中的时候, 假如Producer客户端挂掉了,消息是不是就丢失了?...什么是消息累加器RecordAccumulator
kafka为了提高Producer客户端的发送吞吐量和提高性能,选择了将消息暂时缓存起来,等到满足一定的条件, 再进行批量发送, 这样可以减少网络请求...微信:szzdzhp001
**/
// 找到 batch.size 和 这条消息在batch中的总内存大小的 最大值
int size = Math.max(this.batchSize...关于Batch的结构和消息的结构,我们回头单独用一篇文章来讲解。...注意:这里我们涉及到的 非缓存池中的内存分配, 仅仅指的的内存数字的增加和减少。
问题和答案
发送消息的时候, 当Broker挂掉了,消息体还能写入到消息缓存中吗?