5.2.3. 使用连接器插件扩展 Kafka Connect

流程

1. 通过指定容器 registry in .spec.build.output 和额外的连接器 in. spec.build.plugins 来配置 KafkaConnect 自定义资源：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnect
   metadata:
     name: my-connect-cluster
   spec: 

   1

   
     #...
     build:
       output: 

   2

   
         type: docker
         image: my-registry.io/my-org/my-connect-cluster:latest
         pushSecret: my-registry-credentials
       plugins: 

   3

   
         - name: debezium-postgres-connector
           artifacts:
             - type: tgz
               url: https://repo1.maven.org/maven2/io/debezium/debezium-connector-postgres/1.3.1.Final/debezium-connector-postgres-1.3.1.Final-plugin.tar.gz
               sha512sum: 962a12151bdf9a5a30627eebac739955a4fd95a08d373b86bdcea2b4d0c27dd6e1edd5cb548045e115e33a9e69b1b2a352bee24df035a0447cb820077af00c03
         - name: camel-telegram
           artifacts:
             - type: tgz
               url: https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.7.0/camel-telegram-kafka-connector-0.7.0-package.tar.gz
               sha512sum: a9b1ac63e3284bea7836d7d24d84208c49cdf5600070e6bd1535de654f6920b74ad950d51733e8020bf4187870699819f54ef5859c7846ee4081507f48873479
     #...

   Copy to Clipboard Toggle word wrap

   1

   Kafka Connect 集群的规格。

   2

   （必需）配置推送新镜像的容器注册表。

   3

   （必需）要添加到新容器镜像的连接器插件及其工件列表。每个插件必须至少配置一个 工件。

2. 创建或更新资源：

   $ oc apply -f KAFKA-CONNECT-CONFIG-FILE

   Copy to Clipboard Toggle word wrap
3. 等待新容器镜像构建，并且部署 Kafka Connect 集群。
4. 使用 Kafka Connect REST API 或 KafkaConnector 自定义资源使用您添加的连接器插件。