2.3.4. KafkaConnector リソースの Kafka Connect へのデプロイ

手順

1. examples/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