我有一个相关问题batch.size生产者配置。
当发生什么batch.size已经达到并且生产者应用程序线程发送更多数据？
线程是否会阻塞，直到包含批处理的缓冲区中的空间可用为止？
batch.size以总字节数而不是消息数来衡量批量大小。它控制在向 Kafka 代理发送消息之前要收集多少字节的数据。在不超过可用内存的情况下将其设置得尽可能高。默认值为 16384。
当你使用Producer.send()，您填充生产者上的缓冲区。当缓冲区已满时，生产者将缓冲区发送到 Kafka 代理并开始重新填充缓冲区。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
