如何解决卡夫卡消费者fetch-min-sizefetch.min.bytes是否在等待上述大小被填满? fetch.min.bytes fetch.max.wait.ms
假设有107条记录,每条记录为1kb。如果提取大小为15kb,则在7次迭代中将消耗105kb。现在,仅剩下2kb,是在下一次迭代中获得剩余的2条记录,还是等待更多15kb的累积?假设此之后没有任何记录。
解决方法
它等待直到到达fetch.max.wait.ms
中定义的时间。默认情况下,此值设置为500。您可以在Consumer
fetch.min.bytes
服务器应为获取请求返回的最小数据量。如果没有足够的数据,请求将在等待请求之前等待该数据积累。默认设置为1字节,这意味着只要有一个字节的数据可用,就会立即应答取回请求,或者取回请求超时等待数据到达。将此值设置为大于1的值将导致服务器等待大量数据累积,从而可以以一些额外的延迟为代价提高服务器吞吐量。
fetch.max.wait.ms
如果没有足够的数据立即满足fetch.min.bytes给出的要求,服务器将在回答提取请求之前阻塞的最长时间。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。