3.5. 增加高延迟连接的带宽 Kafka 批处理数据,通过从 Kafka 到客户端(如数据中心之间的连接)实现合理的吞吐量。但是,如果高延迟是问题,您可以增加用于发送和接收消息的缓冲区的大小。 # ... socket.send.buffer.bytes=1048576 socket.receive.buffer.bytes=1048576 # ... 您可以使用 bandwidth-delay 产品 计算来估算缓冲区的最佳大小,这将乘以链路的最大带宽(以字节为单位/秒),以提供保持最大吞吐量所需的大型缓冲区。 前一个下一个