2.9. 外部ソースからの設定値の読み込み

手順

1. 設定プロパティーが含まれる ConfigMap またはシークレットを作成します。

   この例では、my-connector-configuration という名前の ConfigMap にはコネクタープロパティーが含まれます。

   コネクタープロパティーのある ConfigMap の例

   apiVersion: v1
   kind: ConfigMap
   metadata:
     name: my-connector-configuration
   data:
     option1: value1
     option2: value2

2. Kafka Connect 設定で OpenShift Configuration Provider を指定します。

   ここで示される仕様は、シークレットおよび ConfigMap からの値の読み込みをサポートできます。

   ConfigMap からの値に設定された外部ボリュームの例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnect
   metadata:
     name: my-connect
     annotations:
       strimzi.io/use-connector-resources: "true"
   spec:
     # ...
     config:
       # ...
       config.providers: secrets,configmaps 1
       config.providers.secrets.class: io.strimzi.kafka.KubernetesSecretConfigProvider 2
       config.providers.configmaps.class: io.strimzi.kafka.KubernetesConfigMapConfigProvider 3
     # ...

   1

   設定プロバイダーのエイリアスは、他の設定パラメーターを定義するために使用されます。プロバイダーパラメーターは config.providers からのエイリアスを使用し、config.providers.${alias}.class の形式を取ります。

   2

   KubernetesSecretConfigProvider は Secret から値を指定します。

   3

   KubernetesConfigMapConfigProvider は ConfigMap から値を指定します。

3. リソースを作成または更新してプロバイダーを有効にします。

   oc apply -f KAFKA-CONNECT-CONFIG-FILE

4. 外部 ConfigMap の値へのアクセスを許可するロールを作成します。

   ConfigMap から値にアクセスするロールの例

   apiVersion: rbac.authorization.k8s.io/v1
   kind: Role
   metadata:
     name: connector-configuration-role
   rules:
   - apiGroups: [""]
     resources: ["configmaps"]
     resourceNames: ["my-connector-configuration"]
     verbs: ["get"]
   # ...

   このルールは、my-connector-configuration ConfigMap にアクセスするためのロールパーミッションを付与します。

5. ロールバインディングを作成し、ConfigMap が含まれる namespace へのアクセスを許可します。

   ConfigMap が含まれる namespace にアクセスするためのロールバインディングの例

   apiVersion: rbac.authorization.k8s.io/v1
   kind: RoleBinding
   metadata:
     name: connector-configuration-role-binding
   subjects:
   - kind: ServiceAccount
     name: my-connect-connect
     namespace: my-project
   roleRef:
     kind: Role
     name: connector-configuration-role
     apiGroup: rbac.authorization.k8s.io
   # ...

   ロールバインディングは、ロールにmy-project名前空間へのアクセス許可を与えます。

   サービスアカウントは、Kafka Connect デプロイメントによって使用されるものと同じである必要があります。サービスアカウント名の形式は CLUSTER_NAME-connectで、CLUSTER_NAME は KafkaConnect のカスタムリソースの名前です。

6. コネクター設定で ConfigMap を参照します。

   ConfigMap を参照するコネクター設定の例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnector
   metadata:
     name: my-connector
     labels:
       strimzi.io/cluster: my-connect
   spec:
     # ...
     config:
       option: ${configmaps:my-project/my-connector-configuration:option1}
       # ...
   # ...

   ConfigMap のプロパティー値のプレースホルダーは、コネクター設定で参照されます。プレースホルダー構造は、configmaps:PATH-AND-FILE-NAME:PROPERTY です。KubernetesConfigMapConfigProvider は、外部の ConfigMap から option1 プロパティの値を読み込んで抽出します。