重试次数

Kafka 客户端提供重新连接逻辑，但您必须为生产者明确启用重新连接。 欲了解更多信息，请查看 retries 属性。 60 秒内再次进行连接。

重复项

启用重试可能会导致信息重复。 根据连接丢失的时间，生产者可能无法确定服务器是否成功处理消息，因此必须在重新连接时再次发送消息。 设计应用程序以期望重复消息。

如果无法容忍重复，您可以使用 idempotent 生产者功能（来自 Kafka 1.1 ），以防止在重试时出现重复。 欲了解更多信息，请查看 enable.idempotence 属性。

标准计划的具体指导

有关吞吐量指导信息，请参阅“限制和配额——标准”。

企业计划的具体指导

有关吞吐量指导信息，请参阅限制和配额 - 企业。

度量

检测应用程序以了解它们的执行情况。 例如，发送和接收的消息数、消息大小和返回码。 了解应用程序的使用情况可帮助您恰当地配置其资源，例如有关主题的消息的保留时间。

饱和度

当集群可容纳的流量接近上限时，生产者的速度开始变慢，延迟增加，最终出现超时错误等错误。 消息一致性和耐久性可能也会受到影响，具体取决于配置。 有关更多信息，请参阅 消息的一致性和耐久性。

生产者 acks 方式

虽然所有消息都是复制的，但应用程序可以通过使用生产者的 acks 模式属性来控制它们生成的消息传输到服务的稳健性。 此属性提供有关速度和消息丢失风险的选项。 对于 Kafka 3.0，缺省客户机设置为 acks=all (在此版本之前为 acks=1)。 设置 acks=all 表示生产者成功返回，只要它所连接的代理和集群中至少还有一个代理都已确认接收消息。 使用 acks=all 的优点是它提供了最高级别的耐久性，因此可防止消息数据丢失。

同步副本

在 Event Streams 使用的配置中，Kafka 选择一个代理作为每个分区副本的引导者，并选择另外两个代理作为追随者。 来自客户机的消息数据将发送到分区的引导者，并复制到追随者。 如果追随者与领导者保持同步，那么他们将被视为“同步”副本。 根据定义，领导者始终被视为处于同步状态。

如果分区的引导者变得不可用 (可能是因为对代理程序应用了维护)，那么 Kafka 会自动选择另一个同步副本以成为新的引导者。 此过程会快速执行，并由 Kafka 客户机自动处理。

不干净的领导人选举

Event Streams 禁用不干净的引导者选择。 此设置无法更改。

术语 不干净的引导者选择 描述在分区的所有同步副本变为不可用时 Kafka 如何响应。 启用不干净的引导者选择后，Kafka 将通过使第一个副本成为可供分区使用的引导者来恢复，而不考虑它是否处于同步状态。 如果选取为引导者的副本未从先前引导者复制所有消息数据，那么这可能会导致消息数据丢失。 禁用不干净的引导者选择 (如 Event Streams的情况) 时，Kafka 会等待同步副本变为可用，并选择它作为分区的新引导者。 这可避免在启用不干净的领导者选择时可能发生的消息数据丢失。 权衡是恢复可能需要更长时间，因为 Kafka 可能必须等待特定代理程序恢复联机，然后才能使分区可供客户机生成和使用消息数据。