4.2.4. 将 KafkaConnector 资源部署到 Kafka Connect
这个步骤描述了如何将示例 KafkaConnector 部署到 Kafka Connect 集群。
示例 YAML 将创建一个 FileStreamSourceConnector,将许可证文件的每一行发送到 Kafka,作为名为 my-topic 的主题的消息。
先决条件
-
启用 Kafka
Connectors 的 KafkaConnect 部署 - 一个正在运行的 Cluster Operator
步骤
编辑 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 # ...
在 OpenShift 集群中创建
KafkaConnector:oc apply -f examples/connect/source-connector.yaml
检查是否已创建资源:
oc get kctr --selector strimzi.io/cluster=my-connect-cluster -o name