Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

第 139 章 autoRestart 模式参考

用于： KafkaConnectorSpec, KafkaMirrorMaker2ConnectorSpec

AutoRestart 模式属性的完整列表

为连接器和处于 FAILED 状态的任务配置自动重启。

启用后，后台算法会将自动重启应用到每个失败的连接器及其任务。使用公式 n * n + n 来计算增量后台间隔，其中 n 代表之前重启的数量。这个间隔上限为 60 分钟。因此，重启会立即发生，然后在 2、6、12、20、20、30、42、56 分钟后重启，然后以 60 分钟间隔重启。默认情况下，Apache Kafka 的 Streams 会无限期重启连接器及其任务。但是，您可以使用 maxRestarts 属性在重启数量上设置最大值。如果配置了 maxRestarts，并且连接器仍然会在最终重启尝试后失败，则必须手动重启连接器。

对于 Kafka Connect 连接器，使用 KafkaConnector 资源的 autoRestart 属性启用自动重启失败的连接器和任务。

为 Kafka Connect 启用自动重启失败的连接器

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: my-source-connector
spec:
  autoRestart:
    enabled: true
Copy to Clipboard Toggle word wrap

如果您愿意，您还可以为重启数量设置最大限制。

为带有有限重启的 Kafka Connect 启用自动重启失败的连接器

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: my-source-connector
spec:
  autoRestart:
    enabled: true
    maxRestarts: 10
Copy to Clipboard Toggle word wrap

对于 MirrorMaker 2，使用 KafkaMirrorMaker2 资源中的连接器的 autoRestart 属性启用自动重启失败的连接器和任务。

为 MirrorMaker 2 启用自动重启失败的连接器

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:
  name: my-mm2-cluster
spec:
  mirrors:
  - sourceConnector:
      autoRestart:
        enabled: true
      # ...
    heartbeatConnector:
      autoRestart:
        enabled: true
      # ...
    checkpointConnector:
      autoRestart:
        enabled: true
      # ...
Copy to Clipboard Toggle word wrap

139.1. autoRestart 模式属性
复制链接

Expand
属性属性类型描述

enabled

布尔值

是否应该启用或禁用为失败的连接器和任务重启。

maxRestarts

整数

Operator 将尝试的最大连接器数重启。如果在达到这个限制后连接器处于失败状态，用户必须手动重启它。默认为无限个重启。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat