10.17.5. 디렉터리 내에서 여러 파일에서 구성 값 로드

프로세스

1. KafkaConnect 리소스를 구성합니다.

   • DirectoryConfigProvider활성화
   • template 속성을 사용하여 추가 볼륨을 지정합니다.

   외부 속성 파일을 사용하는 Kafka Connect 구성의 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnect
   metadata:
     name: my-connect
   spec:
     # ...
     config:
       config.providers: directory 

   1

   
       config.providers.directory.class: org.apache.kafka.common.config.provider.DirectoryConfigProvider 

   2

   
     #...
     template:
       pod:
         volumes:
           - name: my-user-volume 

   3

   
             secret:
               secretName: my-user 

   4

   
           - name: cluster-ca-volume
             secret:
               secretName: my-cluster-cluster-ca-cert
       connectContainer:
         volumeMounts:
           - name: my-user-volume 

   5

   
             mountPath: /mnt/my-user 

   6

   
           - name: cluster-ca-volume
             mountPath: /mnt/cluster-ca

   1

   구성 공급자의 별칭은 다른 구성 매개 변수를 정의하는 데 사용됩니다.

   2

   DirectoryConfigProvider 는 디렉터리의 파일에서 값을 제공합니다. 매개 변수는 config.providers. ${alias}.class 형식의 별칭 을 사용합니다.

   3

   보안이 포함된 볼륨의 이름입니다.

   4

   시크릿의 이름입니다.

   5

   볼륨 목록의 볼륨 이름과 일치해야 하는 마운트된 볼륨의 이름입니다.

   6

   보안이 마운트된 경로입니다. 이 경로는 /mnt/ 로 시작해야 합니다.

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

   oc apply -f <kafka_connect_configuration_file>

3. 커넥터 구성의 파일 속성을 자리 표시자로 참조합니다.

   파일을 참조하는 커넥터 구성의 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnector
   metadata:
     name: my-source-connector
     labels:
       strimzi.io/cluster: my-connect-cluster
   spec:
     class: io.debezium.connector.mysql.MySqlConnector
     tasksMax: 2
     config:
       # ...
       database.history.producer.security.protocol: SSL
       database.history.producer.ssl.truststore.type: PEM
       database.history.producer.ssl.truststore.certificates: "${directory:/mtn/cluster-ca:ca.crt}"
       database.history.producer.ssl.keystore.type: PEM
       database.history.producer.ssl.keystore.certificate.chain: "${directory:/mnt/my-user:user.crt}"
       database.history.producer.ssl.keystore.key: "${directory:/mnt/my-user:user.key}"
       #...

   자리 표시자 구조는 directory:<path>:<file_name> 입니다. DirectoryConfigProvider 는 마운트된 보안에서 인증 정보를 읽고 추출합니다.