3.5. 增加高延迟连接的带宽

Kafka 批处理数据,通过从 Kafka 到客户端(如数据中心之间的连接)实现合理的吞吐量。但是,如果高延迟是问题,您可以增加用于发送和接收消息的缓冲区的大小。

# ...
socket.send.buffer.bytes=1048576
socket.receive.buffer.bytes=1048576
# ...

您可以使用 bandwidth-delay 产品 计算来估算缓冲区的最佳大小,这将乘以链路的最大带宽(以字节为单位/秒),以提供保持最大吞吐量所需的大型缓冲区。