4.2.4. 将 KafkaConnector 资源部署到 Kafka Connect

步骤

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

   Copy to Clipboard Toggle word wrap

   1

   输入 KafkaConnector 资源的名称。这将在 Kafka Connect 中用作连接器的名称。您可以选择对 OpenShift 资源有效的任何名称。

   2

   输入要在其中创建连接器的 Kafka Connect 集群的名称。

   3

   连接器类的名称或别名。这应该存在于由 Kafka Connect 集群使用的镜像中。

   4

   连接器可以创建的任务数量上限。

   5

   连接器的配置设置。可用的配置选项取决于连接器类。

2. 在 OpenShift 集群中创建 KafkaConnector ：

   oc apply -f examples/connect/source-connector.yaml

   Copy to Clipboard Toggle word wrap

3. 检查是否已创建资源：

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

   Copy to Clipboard Toggle word wrap