4.4. 重启 Kafka Connect 服务

流程

1. 停止 Kafka Connect 服务。

   1. 打开 Kafka Connect 部署的配置：

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

      Copy to Clipboard Toggle word wrap

      部署配置将打开：

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

      Copy to Clipboard Toggle word wrap
   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

      Copy to Clipboard Toggle word wrap

2. 当 Kafka Connect 服务停机时，切换到运行 MySQL 客户端的终端，并在数据库中添加新记录。

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

   Copy to Clipboard Toggle word wrap

3. 重启 Kafka Connect 服务。

   1. 打开 Kafka Connect 服务的部署配置。

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

      Copy to Clipboard Toggle word wrap

      部署配置将打开：

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

      Copy to Clipboard Toggle word wrap
   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

      Copy to Clipboard Toggle word wrap
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.7.3.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
     }
   }

   Copy to Clipboard Toggle word wrap