4.4. Kafka Connect 서비스 다시 시작

프로세스

1. Kafka Connect 서비스를 중지합니다.

   1. Kafka Connect 배포의 구성을 엽니다.

      $ oc edit deployment/my-connect-cluster-connect

      배포 구성이 열립니다.

      apiVersion: apps.openshift.io/v1
      kind: Deployment
      metadata:
        ...
      spec:
        replicas: 1
      ...

   2. spec.replicas 값을 0 으로 변경합니다.
   3. 설정을 저장합니다.

   4. Kafka Connect 서비스가 중지되었는지 확인합니다.

      이 명령은 Kafka Connect 서비스가 완료되었으며 실행 중인 Pod가 없음을 보여줍니다.

      $ oc get pods -l strimzi.io/name=my-connect-cluster-connect
      NAME                                          READY   STATUS      RESTARTS   AGE
      my-connect-cluster-connect-1-dxcs9            0/1     Completed   0          7h

2. Kafka Connect 서비스가 중단되는 동안 MySQL 클라이언트를 실행하는 터미널로 전환하고 새 레코드를 데이터베이스에 추가합니다.

   mysql> INSERT INTO customers VALUES (default, "Sarah", "Thompson", "kitt@acme.com");

3. Kafka Connect 서비스를 다시 시작합니다.

   1. Kafka Connect 서비스의 배포 구성을 엽니다.

      $ oc edit deployment/my-connect-cluster-connect

      배포 구성이 열립니다.

      apiVersion: apps.openshift.io/v1
      kind: Deployment
      metadata:
        ...
      spec:
        replicas: 0
      ...

   2. spec.replicas 값을 1 로 변경합니다.
   3. 배포 구성을 저장합니다.

   4. Kafka Connect 서비스가 다시 시작되었는지 확인합니다.

      이 명령은 Kafka Connect 서비스가 실행 중이고 Pod가 준비되었음을 보여줍니다.

      $ oc get pods -l strimzi.io/name=my-connect-cluster-connect
      NAME                                          READY   STATUS      RESTARTS   AGE
      my-connect-cluster-connect-2-q9kkl            1/1     Running     0          74s

4. kafka-console-consumer.sh 를 실행 중인 터미널로 전환합니다. 도착한 대로 새 이벤트가 열립니다.

5. Kafka Connect가 오프라인 상태일 때 생성한 레코드를 검사합니다(읽기 쉽도록 포맷).

   {
     ...
     "payload":{
       "id":1005
     }
   }
   {
     ...
     "payload":{
       "before":null,
       "after":{
          "id":1005,
          "first_name":"Sarah",
          "last_name":"Thompson",
          "email":"kitt@acme.com"
       },
       "source":{
          "version":"2.3.4.Final",
          "connector":"mysql",
          "name":"dbserver1",
          "ts_ms":1582581502000,
          "snapshot":"false",
          "db":"inventory",
          "table":"customers",
          "server_id":223344,
          "gtid":null,
          "file":"mysql-bin.000004",
          "pos":364,
          "row":0,
          "thread":5,
          "query":null
       },
       "op":"c",
       "ts_ms":1582581502317
     }
   }