5.2.4. 创建和管理连接器

KafkaConnectors 允许您以 OpenShift 原生的方式为 Kafka Connect 创建和管理连接器实例，因此不需要 cURL 等 HTTP 客户端。与其他 Kafka 资源一样，您可以在部署至 OpenShift 集群的 KafkaConnector YAML 文件中声明连接器所需的状态，以创建连接器实例。KafkaConnector 资源必须部署到与其链接的 Kafka Connect 集群相同的命名空间中。

您可以通过更新对应的 KafkaConnector 资源并应用更新来管理正在运行的连接器实例。注释用于手动重启连接器实例和连接器任务。您可以通过删除对应的 KafkaConnector 来删除连接器。

为确保与早期版本的 AMQ Streams 兼容，KafkaConnectors 默认被禁用。要为 Kafka Connect 集群启用它们，您必须在 KafkaConnect 资源上使用注解。具体步骤，请参阅 OpenShift 中使用 AMQ Streams 中的 配置 Kafka Connect。

启用 KafkaConnectors 后，Cluster Operator 开始监视它们。它更新正在运行的连接器实例的配置，以匹配其 KafkaConnectors 中定义的配置。

AMQ Streams 包括 一个名为 example /connect/source-connector.yaml 的 KafkaConnect or 示例。您可以使用此示例创建和管理 FileStreamSourceConnector 和 FileStreamSinkConnector，如 第 5.2.5 节 “部署示例 KafkaConnector 资源” 所述。