4.2.4. 将 KafkaConnector 资源部署到 Kafka Connect

这个步骤描述了如何将示例 KafkaConnector 部署到 Kafka Connect 集群。

示例 YAML 将创建一个 FileStreamSourceConnector,将许可证文件的每一行发送到 Kafka,作为名为 my-topic 的主题的消息。

先决条件

步骤

  1. 编辑 example /connect/source-connector.yaml 文件:

    apiVersion: kafka.strimzi.io/v1alpha1
    kind: KafkaConnector
    metadata:
      name: my-source-connector 1
      labels:
        strimzi.io/cluster: my-connect-cluster 2
    spec:
      class: org.apache.kafka.connect.file.FileStreamSourceConnector 3
      tasksMax: 2 4
      config: 5
        file: "/opt/kafka/LICENSE"
        topic: my-topic
        # ...
    1
    输入 KafkaConnector 资源的名称。这将在 Kafka Connect 中用作连接器的名称。您可以选择对 OpenShift 资源有效的任何名称。
    2
    输入要在其中创建连接器的 Kafka Connect 集群的名称。
    3
    连接器类的名称或别名。这应该存在于由 Kafka Connect 集群使用的镜像中。
    4
    连接器可以创建的任务数量上限。
    5
    连接器的配置设置。可用的配置选项取决于连接器类。
  2. 在 OpenShift 集群中创建 KafkaConnector

    oc apply -f examples/connect/source-connector.yaml
  3. 检查是否已创建资源:

    oc get kctr --selector strimzi.io/cluster=my-connect-cluster -o name