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

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