10.8.5. 커넥터 오프셋 변경

프로세스

1. KafkaConnector 리소스를 편집하여 커넥터를 중지하고 alterOffsets 구성을 포함합니다.

   커넥터를 중지하고 오프셋을 변경하는 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnector
   metadata:
     name: my-source-connector
     labels:
       strimzi.io/cluster: my-connect-cluster
   spec:
     state: stopped 

   1

   
     alterOffsets:
       fromConfigMap: 

   2

   
         name: my-connector-offsets 

   3

   
     # ...

   1

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

   2

   업데이트를 제공하는 구성 맵에 대한 참조입니다.

   3

   이 예제에서 my-connector-offsets 라는 구성 맵의 이름입니다.

2. 구성 맵을 편집하여 변경합니다.

   이 예제에서는 소스 커넥터의 오프셋 위치를 15000으로 재설정하고 있습니다.

   소스 커넥터 오프셋 목록 구성 예

   apiVersion: v1
   kind: ConfigMap
   metadata:
     # ...
   data:
     offsets.json: |- 

   1

   
       {
         "offsets" : [ {
           "partition" : {
             "filename" : "/data/myfile.txt"
           },
           "offset" : {
             "position" : 15000 

   2

   
           }
         } ]
       }

   1

   offsets.json 속성 내에서 편집해야 합니다.

   2

   소스 파티션의 업데이트된 오프셋 위치입니다.

3. KafkaConnector 리소스에 주석을 달아 오프셋 위치를 업데이트하려면 명령을 실행합니다.

   oc annotate kafkaconnector my-source-connector strimzi.io/connector-offsets=alter -n <namespace>

   이 주석은 업데이트 작업이 성공하거나 리소스에서 수동으로 제거될 때까지 유지됩니다.

4. 절차를 사용하여 커넥터 오프셋을 나열 하여 변경 사항을 확인합니다.

5. 상태를 실행 중으로 변경하여 커넥터를 다시 시작합니다.

   커넥터를 시작하는 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnector
   metadata:
     name: my-source-connector
     labels:
       strimzi.io/cluster: my-connect-cluster
   spec:
     state: running
     # ...