9.6. Kafka Connect 구성

프로세스

1. KafkaUser 리소스에서 권한 부여 속성을 편집하여 사용자에게 액세스 권한을 제공합니다.

   액세스 권한은 리터럴 이름 값을 사용하여 Kafka Connect 주제 및 클러스터 그룹에 대해 구성됩니다. 다음 표에서는 주제 및 클러스터 그룹 ID에 대해 구성된 기본 이름을 보여줍니다.

   Expand

   표 9.2. 액세스 권한 구성의 이름

   속성	이름
   offset.storage.topic	connect-cluster-offsets
   status.storage.topic	connect-cluster-status
   config.storage.topic	connect-cluster-configs
   group	connect-cluster

   Show more

   이 예제 구성에서 기본 이름은 액세스 권한을 지정하는 데 사용됩니다. Kafka Connect 인스턴스에 다른 이름을 사용하는 경우 ACL 구성에서 해당 이름을 사용합니다.

   간단한 권한 부여를 위한 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaUser
   metadata:
     name: my-user
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     # ...
     authorization:
       type: simple
       acls:
         # access to offset.storage.topic
         - resource:
             type: topic
             name: connect-cluster-offsets
             patternType: literal
           operations:
             - Create
             - Describe
             - Read
             - Write
           host: "*"
         # access to status.storage.topic
         - resource:
             type: topic
             name: connect-cluster-status
             patternType: literal
           operations:
             - Create
             - Describe
             - Read
             - Write
           host: "*"
         # access to config.storage.topic
         - resource:
             type: topic
             name: connect-cluster-configs
             patternType: literal
           operations:
             - Create
             - Describe
             - Read
             - Write
           host: "*"
         # cluster group
         - resource:
             type: group
             name: connect-cluster
             patternType: literal
           operations:
             - Read
           host: "*"

   Copy to Clipboard Toggle word wrap

2. 리소스를 생성하거나 업데이트합니다.

   oc apply -f KAFKA-USER-CONFIG-FILE

   Copy to Clipboard Toggle word wrap

프로세스

1. 일시 중지 또는 중지하려는 커넥터를 제어하는 KafkaConnector 사용자 정의 리소스의 이름을 찾습니다.

   oc get KafkaConnector

   Copy to Clipboard Toggle word wrap

2. KafkaConnector 리소스를 편집하여 커넥터를 중지하거나 일시 중지합니다.

   Kafka Connect 커넥터를 중지하는 구성의 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnector
   metadata:
     name: my-source-connector
     labels:
       strimzi.io/cluster: my-connect-cluster
   spec:
     class: org.apache.kafka.connect.file.FileStreamSourceConnector
     tasksMax: 2
     config:
       file: "/opt/kafka/LICENSE"
       topic: my-topic
     state: stopped
     # ...

   Copy to Clipboard Toggle word wrap

   상태 구성을 중지 또는 일시 중지 하도록 변경합니다. 이 속성이 실행 중이 아닌 경우 커넥터의 기본 상태입니다.

3. KafkaConnector 구성에 변경 사항을 적용합니다.

   상태를 실행 중이거나 구성을 제거하여 커넥터를 다시 시작할 수 있습니다.

프로세스

1. 재시작할 Kafka 커넥터를 제어하는 KafkaConnector 사용자 정의 리소스의 이름을 찾습니다.

   oc get KafkaConnector

   Copy to Clipboard Toggle word wrap

2. OpenShift에서 KafkaConnector 리소스에 주석을 달아 커넥터를 다시 시작합니다.

   oc annotate KafkaConnector <kafka_connector_name> strimzi.io/restart="true"

   Copy to Clipboard Toggle word wrap

   재시작 주석은 true 로 설정됩니다.

3. 다음 조정이 발생할 때까지 기다립니다(기본적으로 2분마다).

   조정 프로세스에서 주석을 감지한 한 Kafka 커넥터가 다시 시작됩니다. Kafka Connect에서 재시작 요청을 수락하면 KafkaConnector 사용자 정의 리소스에서 주석이 제거됩니다.

프로세스

1. 재시작할 Kafka 커넥터 작업을 제어하는 KafkaConnector 사용자 정의 리소스의 이름을 찾습니다.

   oc get KafkaConnector

   Copy to Clipboard Toggle word wrap

2. KafkaConnector 사용자 정의 리소스에서 재시작할 작업의 ID를 찾습니다.

   oc describe KafkaConnector <kafka_connector_name>

   Copy to Clipboard Toggle word wrap

   작업 ID는 0부터 시작하여 음수가 아닌 정수입니다.

3. OpenShift에서 KafkaConnector 리소스에 주석을 달아 커넥터 작업을 다시 시작하려면 ID를 사용합니다.

   oc annotate KafkaConnector <kafka_connector_name> strimzi.io/restart-task="0"

   Copy to Clipboard Toggle word wrap

   이 예에서는 작업 0 이 다시 시작됩니다.

4. 다음 조정이 발생할 때까지 기다립니다(기본적으로 2분마다).

   조정 프로세스에서 주석을 감지한 한 Kafka 커넥터 작업이 다시 시작됩니다. Kafka Connect에서 재시작 요청을 수락하면 KafkaConnector 사용자 정의 리소스에서 주석이 제거됩니다.