第 3 章 从外部来源加载配置值

流程

1. 创建包含配置属性的 ConfigMap 或 Secret。

   在本例中，名为 my-connector-configuration 的 ConfigMap 对象包含 connector 属性：

   使用连接器属性的 ConfigMap 示例

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

2. 在 Kafka Connect 配置中指定 OpenShift Configuration Provider。

   此处所示的规格支持从 secret 和 ConfigMap 中加载值。

   启用 OpenShift Configuration Provider 的 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

   配置提供程序的别名用于定义其他配置参数。provider 参数使用 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. 创建一个角色绑定，以允许访问包含配置映射的命名空间。

   访问包含配置映射的命名空间的角色绑定示例

   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> : & lt;property>。KubernetesConfigMapConfigProvider 从外部配置映射读取并提取 option1 属性值。