更加深刻理解Kafka--Producer篇(下)

批次 积累器在建立批次以前,就在堆上为它预分配一段空间,这段空间用于装载消息。消息最终会顺序落到内存块中造成消息集。批次的逻辑结构以下: web 5.0.1 * MemoryRecords即消息集的抽象,它容纳0到多条Record。 * Record则表明消息在内存中的状态,即按二进制协议格式化以后的消息结构,它是消息集的元素。 * 用户可经过compression.type配置压缩方式,开启压缩
相关文章
相关标签/搜索