1.6. 支持停止运行连接器


现在,您可以停止 Kafka Connect 或 Kafka MirrorMaker 2 连接器。与暂停状态相比,连接器和任务保持实例化,当只停止连接器的配置但实际上没有运行时。从运行停止连接器可能更适合长时间,而不是只暂停。暂停的连接器会加快恢复速度,但已停止的连接器可以释放内存和资源。

KafkaConnectorSpec 模式和 KafkaMirrorMaker2ConnectorSpec 模式的 pause 属性已弃用。相反,两个模式现在都包含一个新的 state 属性。state 属性允许您配置以下值之一: 运行暂停 和停止

注意

对 MirrorMaker 2 的支持 有一个已知问题。这个问题将在 AMQ Streams 的下一个发行版本中解决。

例如,如果要停止 Kafka Connect 连接器资源,您可以将 状态更改为 在配置中 停止

停止 Kafka Connect 连接器的配置示例

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: my-source-connector
  labels:
    strimzi.io/cluster: my-connect-cluster
spec:
  class: org.apache.kafka.connect.file.FileStreamSourceConnector
  tasksMax: 2
  config:
    file: "/opt/kafka/LICENSE"
    topic: my-topic
  state: stopped
    # ...

停止 Kafka MirrorMaker 2 连接器的配置示例

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:
  name: my-mirror-maker2
spec:
  version: 3.6.0
  replicas: 3
  connectCluster: "my-cluster-target"
  clusters:
    # ...
  mirrors:
  - sourceCluster: "my-cluster-source"
    targetCluster: "my-cluster-target"
    sourceConnector:
      tasksMax: 10
      autoRestart:
        enabled: true
      state: stopped
  # ...

注意

此功能至少需要 Kafka 3.5.x 才能工作。只有 pause 操作可以和旧版 Kafka 一起工作。

使用以下 REST 端点,Kafka Connect REST API (没有启用 KafkaConnector Operator 时)也支持停止和暂停操作:

  • PUT /connectors/<connector_name>/stop
  • PUT /connectors/<connector_name>/pause

PUT /connectors/<connector_name>/resume 请求重启已停止并暂停的连接器。

请参阅 KafkaConnectorSpec 模式参考KafkaMirrorMaker2ConnectorSpec 模式参考

Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2026 Red Hat
返回顶部