kafka消息生产速度快于发送速度,buffer.memory会生效吗?

lphu 发表于: 2021-01-25   最后更新时间: 2021-01-26 10:21:28   2,034 游览
batch.size=16K
buffer.memory=8M
linger.ms=0

特定业务场景下,堆区128M, 如果消息生产速度远大于发送的速度, buffer.memory会限制住缓存区大小不再生成producerBatch对象吗?

发表于 2021-01-25
添加评论

有效,生产者将阻塞max.block.ms之后,抛出异常。
但是,linger.ms配置0,无延迟发送,理论上你的消息不会停留,batch.size、buffer.memory永远不会达到。

你的答案

查看kafka相关的其他问题或提一个您自己的问题