麦克斯·林。航班请求。每连接Kafka生产者配置

Question

我有一个关于最大值的问题。航班请求。每连接Kafka生产者配置。此配置适用于发送到代理的每封邮件还是批处理中的所有邮件？

例如，如果我的批处理大小为16KB，每条消息的大小为1KB，则批处理将有16条消息。

如果麦克斯在。航班请求。每连接值为1，那么生产者是否会从该批发送一条消息，并在从该批发送下一条消息之前等待确认？

或

生产者将发送批处理中的所有消息，并在发送下一个批处理之前等待确认？

Answer 1

max.in.flight.requests.per.connection（流水线）

此属性在生产者max.in.flight.requests.per.connection属性上配置。此属性适用于批量消息，而不是单个消息。

麦克斯·林。航班请求。每connection=1意味着一次将发送一批记录，并等待代理没有收到响应。

在阻塞之前，客户端在单个连接上发送的最大未确认请求数。如果此设置大于1，则当生产者将分组的批次发送给代理时，将使用管道。

这提高了吞吐量，但如果发送失败，则存在由于重试（如果启用了重试）而导致无序交付的风险。

还要注意，过度的流水线操作会降低吞吐量。