将linger.ms保持在0的含义

Question

我们使用的是Kafka0.10.2.1。该文档规定，即使缓冲区未满，也可以发送缓冲区-

默认情况下，即使缓冲区中有额外的未使用空间，也可以立即发送缓冲区。但是，如果要减少请求的数量，可以设置linger。ms设置为大于0的值。

然而，它还表示，即使逗留时间设置为0ms-，生产者也会尝试批量请求。

请注意，及时到达的记录通常会批处理在一起，即使存在延迟。ms=0，因此在重负荷下，无论采用何种玲珑配置，都会进行配料；但是，如果将其设置为大于0的值，则在不处于最大负载的情况下，以较小的延迟为代价，会导致更少、更高效的请求。

直观地看，任何类型的批处理似乎都需要一些延迟时间，而实现0的延迟时间的唯一方法是使代理调用同步。显然，将延迟时间保持在0似乎不会像阻止发送呼叫那样损害性能，但似乎会对性能产生一些影响。有人能澄清一下上面的文件是怎么说的吗？

Answer 1

如果linger.ms=0，记录将尽快发送，并且请求很多，这可能会影响性能。通过在中等/高负载下增加linger.ms来强制等待会优化批处理的使用并提高吞吐量。这也取决于记录大小，批处理中容纳的记录越大越少（batch.size默认为16Kb）。

基本上，它是请求数量和吞吐量之间的折衷，这实际上取决于您的场景，但是立即发送并不能充分利用批处理和压缩（如果启用），我建议使用不同的linger值运行一些度量。ms例如0/5/10/50/200

一般来说，我会建议设置linger。太太

参考资料：

• KIP-91
• cloudurable的精彩教程
• 官方文件v0。10.2

Answer 2

文档说，即使你将逗留时间设置为0，你可能最终会有一点点的批处理负载，因为记录被添加到发送速度比发送线程可以调度它们的速度要快。这个设置是为了最小的延迟而优化的。如果你真正关心的性能指标是吞吐量，你应该增加一点逗留时间来批处理更多的记录，这就是文档想要的。在这种情况下，与其说是同步发送。更深入的信息