第3章 外部ソースからの設定値の読み込み

手順

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 からの値の読み込みをサポートできます。

   OpenShift 設定プロバイダーを有効にする Kafka Connect の設定例

   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 は設定マップから値を指定します。

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

   oc apply -f <kafka_connect_configuration_file>

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

   設定マップから値にアクセスするロールの例

   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 設定マップにアクセスするためのロールパーミッションを付与します。

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

   設定マップが含まれる 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. コネクター設定で設定マップを参照します。

   設定マップを参照するコネクター設定の例

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

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