第 132 章 autoRestart 模式参考

用于： KafkaConnectorSpec, KafkaMirrorMaker2ConnectorSpec

AutoRestart 模式属性的完整列表

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

启用后，后台算法会将自动重启应用到每个失败的连接器及其任务。

Operator 在协调时尝试自动重启。如果第一次尝试失败，Operator 最多会进行 6 次尝试。每次重启尝试之间的持续时间从 2 到 30 分钟增加。每次重启后，失败的连接器和任务都从 FAILED 传输到 RESTARTING。如果在最终尝试后重启失败，则连接器配置可能会出现问题。连接器和任务处于 FAILED 状态，您必须手动重启。您可以通过使用 strimzi.io/restart: "true" 注解 KafKaConnector 自定义资源来完成此操作。

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

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: my-source-connector
spec:
  autoRestart:
    enabled: true

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

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
      # ...