我遇到了两个关于排序的短语，
- 生产者发送到特定主题分区的消息将被 按发送顺序附加。也就是说，如果发送了一条记录 M1 由与记录 M2 相同的生产者发送，首先发送 M1，然后发送 M1 将具有比 M2 更低的偏移量并在日志中更早出现。
另一个
- (config param) max.in.flight.requests.per.connection - 最大数量 客户端将在单个连接上发送的未确认请求 在阻塞之前。 请注意，如果此设置设置为大于 1 并且有失败的发送，有消息重新排序的风险 由于重试（即，如果启用重试）。
问题是，如果像提到的 #2 那样发送失败，订单是否仍会保留到特定分区？如果一条消息存在潜在问题，则以下所有消息将被丢弃“以保留每个分区的顺序”，或者将发送“正确”消息并将失败的消息通知给应用程序？
【问题讨论】：
标签： apache-kafka kafka-producer-api
“如果像提到的 #2 那样发送失败，订单是否仍会保留到特定分区？”
正如您复制的文档部分所述，存在更改顺序的风险。
想象一下，您有一个主题，例如一个分区。您将retries 设置为100，将max.in.flight.requests.per.connection 设置为大于一的5。请注意，仅当您将 acks 设置为 1 或“全部”时，重试才有意义。
如果您计划按 K1、K2、K3、K4、K5 的顺序生成以下消息，并且您的生产者需要一些时间来
最多可以并行处理 5 个请求（基于 max.in.flight.request.per.connection 的设置）。现在，生成“K3”有一些问题，它进入了重试循环，可以生成消息 K4 和 K5，因为请求已经在进行中。
您的主题最终会按以下顺序显示消息：K1、K2、K4、K5、K3。
如果您在 Kafka Producer 中启用 idempotency，则仍然可以保证排序，如Ordering guarantees when using idempotent Kafka Producer中所述
【讨论】：
max.in.flight.requests.per.connection的默认值其实是5。