3장. 외부 소스에서 구성 값 로드

절차

1. 구성 속성이 포함된 ConfigMap 또는 Secret 을 생성합니다.

   이 예에서 my-connector-configuration 이라는 ConfigMap 오브젝트에는 커넥터 속성이 포함되어 있습니다.

   커넥터 속성이 있는 ConfigMap 의 예

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

   Copy to Clipboard Toggle word wrap

2. Kafka Connect 구성에서 OpenShift 구성 공급자를 지정합니다.

   여기에 표시된 사양은 시크릿 및 구성 맵의 값 로드를 지원할 수 있습니다.

   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

   
     # ...

   Copy to Clipboard Toggle word wrap

   1

   구성 공급자의 별칭은 다른 구성 매개 변수를 정의하는 데 사용됩니다. 공급자 매개변수는 config.providers. ${alias}.class 형식의 별칭 을 사용합니다.

   2

   KubernetesSecretConfigProvider 는 보안의 값을 제공합니다.

   3

   KubernetesConfigMapConfigProvider 는 구성 맵의 값을 제공합니다.

3. 공급자를 활성화하도록 리소스를 생성하거나 업데이트합니다.

   oc apply -f <kafka_connect_configuration_file>

   Copy to Clipboard Toggle word wrap

4. 외부 구성 맵의 값에 대한 액세스를 허용하는 역할을 생성합니다.

   구성 맵에서 값에 액세스하는 역할의 예

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

   Copy to Clipboard Toggle word wrap

   규칙은 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
   # ...

   Copy to Clipboard Toggle word wrap

   역할 바인딩은 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}
       # ...
   # ...

   Copy to Clipboard Toggle word wrap

   구성 맵의 속성 값에 대한 자리 표시자는 커넥터 구성에서 참조됩니다. 자리 표시자 구조는 configmaps: <path_and_file_name > : <property> 입니다. KubernetesConfigMapConfigProvider 는 외부 구성 맵에서 option1 속성 값을 읽고 추출합니다.