如何解决max.in.flight.requests.per.connection kafka 生产者配置
我有一个关于 max.in.flight.requests.per.connection kafka 生产者配置的问题。 此配置是应用于每条消息还是批量发送给代理的所有消息?
例如,如果我的批大小为 16KB,每条消息的大小为 1 KB,那么批将有 16 条消息。
如果 max.in.flight.requests.per.connection 值为 1,那么生产者是否会从批次中发送一条消息并等待确认,然后再从批次中发送下一条消息?
或
producer 会发送该批次中的所有消息并等待确认后再发送下一个批次吗?
解决方法
max.in.flight.requests.per.connection (pipelining)
此属性在生产者 max.in.flight.requests.per.connection 属性上配置。 This property applies to the batch of messages not to individual messages.
max.in.flight.requests.per.connection=1 表示一次发送一批记录,等待代理没有收到响应。
客户端在阻塞前将在单个连接上发送的最大未确认请求数。如果此设置大于 1,则在生产者将分组批次发送给代理时使用流水线。
这提高了吞吐量,但如果发送失败,则存在由于重试(如果启用重试)而导致无序交付的风险。
另请注意,过多的流水线操作会降低吞吐量。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。