在 OpenShift 中部署和升级 AMQ Streams

流程

1. 编辑 AMQ Streams 安装文件，以使用 Cluster Operator 将要安装到的命名空间。

   例如，在此流程中，Cluster Operator 安装到命名空间 < my_cluster_operator_namespace > 中。

   在 Linux 上，使用：

   sed -i 's/namespace: .*/namespace: <my_cluster_operator_namespace>/' install/cluster-operator/*RoleBinding*.yaml

   在 MacOS 上，使用：

   sed -i '' 's/namespace: .*/namespace: <my_cluster_operator_namespace>/' install/cluster-operator/*RoleBinding*.yaml

2. 部署 Cluster Operator：

   oc create -f install/cluster-operator -n <my_cluster_operator_namespace>

3. 检查部署的状态：

   oc get deployments -n <my_cluster_operator_namespace>

   输出显示了部署名称和就绪状态

   NAME                      READY  UP-TO-DATE  AVAILABLE
   strimzi-cluster-operator  1/1    1           1

   READY 显示 ready/expected 的副本数量。当 AVAILABLE 输出显示为 1 时，部署成功。

流程

1. 编辑 AMQ Streams 安装文件，以使用 Cluster Operator 将要安装到的命名空间。

   例如，在此流程中，Cluster Operator 安装到命名空间 < my_cluster_operator_namespace > 中。

   在 Linux 上，使用：

   sed -i 's/namespace: .*/namespace: <my_cluster_operator_namespace>/' install/cluster-operator/*RoleBinding*.yaml

   在 MacOS 上，使用：

   sed -i '' 's/namespace: .*/namespace: <my_cluster_operator_namespace>/' install/cluster-operator/*RoleBinding*.yaml

2. 编辑 install/cluster-operator/060-Deployment-strimzi-cluster-operator.yaml 文件，以添加 Cluster Operator 将监视到 STRIMZI_NAMESPACE 环境变量的所有命名空间列表。

   例如，在此流程中，Cluster Operator 将监控命名空间 watched-namespace-1、watched-namespace-2、watched-namespace-3。

   apiVersion: apps/v1
   kind: Deployment
   spec:
     # ...
     template:
       spec:
         serviceAccountName: strimzi-cluster-operator
         containers:
         - name: strimzi-cluster-operator
           image: registry.redhat.io/amq7/amq-streams-rhel8-operator:2.2.2
           imagePullPolicy: IfNotPresent
           env:
           - name: STRIMZI_NAMESPACE
             value: watched-namespace-1,watched-namespace-2,watched-namespace-3

3. 对于每个命名空间，安装 RoleBindings。

   在这个示例中，将这些命令的 watched-namespace 替换为在前一步中列出的命名空间，为 watched-namespace-1, watched-namespace-2, watched-namespace-3 重复这个操作：

   oc create -f install/cluster-operator/020-RoleBinding-strimzi-cluster-operator.yaml -n <watched_namespace>
   oc create -f install/cluster-operator/031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml -n <watched_namespace>

4. 部署 Cluster Operator：

   oc create -f install/cluster-operator -n <my_cluster_operator_namespace>

5. 检查部署的状态：

   oc get deployments -n <my_cluster_operator_namespace>

   输出显示了部署名称和就绪状态

   NAME                      READY  UP-TO-DATE  AVAILABLE
   strimzi-cluster-operator  1/1    1           1

   READY 显示 ready/expected 的副本数量。当 AVAILABLE 输出显示为 1 时，部署成功。

流程

1. 编辑 AMQ Streams 安装文件，以使用 Cluster Operator 将要安装到的命名空间。

   例如，在此流程中，Cluster Operator 安装到命名空间 < my_cluster_operator_namespace > 中。

   在 Linux 上，使用：

   sed -i 's/namespace: .*/namespace: <my_cluster_operator_namespace>/' install/cluster-operator/*RoleBinding*.yaml

   在 MacOS 上，使用：

   sed -i '' 's/namespace: .*/namespace: <my_cluster_operator_namespace>/' install/cluster-operator/*RoleBinding*.yaml

2. 编辑 install/cluster-operator/060-Deployment-strimzi-cluster-operator.yaml 文件，将 STRIMZI_NAMESPACE 环境变量的值设置为 *。

   apiVersion: apps/v1
   kind: Deployment
   spec:
     # ...
     template:
       spec:
         # ...
         serviceAccountName: strimzi-cluster-operator
         containers:
         - name: strimzi-cluster-operator
           image: registry.redhat.io/amq7/amq-streams-rhel8-operator:2.2.2
           imagePullPolicy: IfNotPresent
           env:
           - name: STRIMZI_NAMESPACE
             value: "*"
           # ...

3. 创建 ClusterRoleBindings，为 Cluster Operator 的所有命名空间授予集群范围的访问权限。

   oc create clusterrolebinding strimzi-cluster-operator-namespaced --clusterrole=strimzi-cluster-operator-namespaced --serviceaccount <my_cluster_operator_namespace>:strimzi-cluster-operator
   oc create clusterrolebinding strimzi-cluster-operator-entity-operator-delegation --clusterrole=strimzi-entity-operator --serviceaccount <my_cluster_operator_namespace>:strimzi-cluster-operator

   将 <my_cluster_operator_namespace > 替换为您要安装 Cluster Operator 的命名空间。

4. 将 Cluster Operator 部署到您的 OpenShift 集群。

   oc create -f install/cluster-operator -n <my_cluster_operator_namespace>

5. 检查部署的状态：

   oc get deployments -n <my_cluster_operator_namespace>

   输出显示了部署名称和就绪状态

   NAME                      READY  UP-TO-DATE  AVAILABLE
   strimzi-cluster-operator  1/1    1           1

   READY 显示 ready/expected 的副本数量。当 AVAILABLE 输出显示为 1 时，部署成功。

流程

1. 创建和部署 临时或 持久的 集群。

   对于开发或测试，您可能需要使用临时集群。您可以随时使用持久的集群。

   • 创建和部署 临时 集群：

     oc apply -f examples/kafka/kafka-ephemeral.yaml

   • 创建和部署 持久 集群：

     oc apply -f examples/kafka/kafka-persistent.yaml

2. 检查部署的状态：

   oc get pods -n <my_cluster_operator_namespace>

   输出显示了 pod 名称和就绪度

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   my-cluster-kafka-0          1/1     Running   0
   my-cluster-kafka-1          1/1     Running   0
   my-cluster-kafka-2          1/1     Running   0
   my-cluster-zookeeper-0      1/1     Running   0
   my-cluster-zookeeper-1      1/1     Running   0
   my-cluster-zookeeper-2      1/1     Running   0

   my-cluster 是 Kafka 集群的名称。

   使用默认部署，您要安装一个 Entity Operator 集群、3 Kafka pod 和 3 ZooKeeper pod。

   READY 显示 ready/expected 的副本数量。当 STATUS 显示为 Running 时，部署成功。

流程

1. 编辑 Kafka 资源的 entityOperator 属性，使其包含 topicOperator ：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     #...
     entityOperator:
       topicOperator: {}
       userOperator: {}

2. 根据 EntityTopicOperatorSpec schema reference 中介绍的属性配置 Topic Operator spec。

   如果您希望所有属性使用它们的默认值，请使用空对象({})。

3. 创建或更新资源：

   使用 oc apply:

   oc apply -f <kafka_configuration_file>

4. 检查部署的状态：

   oc get pods -n <my_cluster_operator_namespace>

   输出显示了 pod 名称和就绪度

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   # ...

   my-cluster 是 Kafka 集群的名称。

   READY 显示 ready/expected 的副本数量。当 STATUS 显示为 Running 时，部署成功。

流程

1. 编辑 Kafka 资源的 entityOperator 属性，使其包含 userOperator ：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     #...
     entityOperator:
       topicOperator: {}
       userOperator: {}

2. 根据 EntityUserOperatorSpec schema reference 中介绍的属性配置User Operator spec。

   如果您希望所有属性使用它们的默认值，请使用空对象({})。

3. 创建或更新资源：

   oc apply -f <kafka_configuration_file>

4. 检查部署的状态：

   oc get pods -n <my_cluster_operator_namespace>

   输出显示了 pod 名称和就绪度

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   # ...

   my-cluster 是 Kafka 集群的名称。

   READY 显示 ready/expected 的副本数量。当 STATUS 显示为 Running 时，部署成功。

流程

1. 编辑 install/topic-operator/05-Deployment-strimzi-topic-operator.yaml 独立部署文件中的 env 属性。

   独立主题 Operator 部署配置示例

   apiVersion: apps/v1
   kind: Deployment
   metadata:
     name: strimzi-topic-operator
     labels:
       app: strimzi
   spec:
     # ...
     template:
       # ...
       spec:
         # ...
         containers:
           - name: strimzi-topic-operator
             # ...
             env:
               - name: STRIMZI_NAMESPACE 1
                 valueFrom:
                   fieldRef:
                     fieldPath: metadata.namespace
               - name: STRIMZI_KAFKA_BOOTSTRAP_SERVERS 2
                 value: my-kafka-bootstrap-address:9092
               - name: STRIMZI_RESOURCE_LABELS 3
                 value: "strimzi.io/cluster=my-cluster"
               - name: STRIMZI_ZOOKEEPER_CONNECT 4
                 value: my-cluster-zookeeper-client:2181
               - name: STRIMZI_ZOOKEEPER_SESSION_TIMEOUT_MS 5
                 value: "18000"
               - name: STRIMZI_FULL_RECONCILIATION_INTERVAL_MS 6
                 value: "120000"
               - name: STRIMZI_TOPIC_METADATA_MAX_ATTEMPTS 7
                 value: "6"
               - name: STRIMZI_LOG_LEVEL 8
                 value: INFO
               - name: STRIMZI_TLS_ENABLED 9
                 value: "false"
               - name: STRIMZI_JAVA_OPTS 10
                 value: "-Xmx=512M -Xms=256M"
               - name: STRIMZI_JAVA_SYSTEM_PROPERTIES 11
                 value: "-Djavax.net.debug=verbose -DpropertyName=value"
               - name: STRIMZI_PUBLIC_CA 12
                 value: "false"
               - name: STRIMZI_TLS_AUTH_ENABLED 13
                 value: "false"
               - name: STRIMZI_SASL_ENABLED 14
                 value: "false"
               - name: STRIMZI_SASL_USERNAME 15
                 value: "admin"
               - name: STRIMZI_SASL_PASSWORD 16
                 value: "password"
               - name: STRIMZI_SASL_MECHANISM 17
                 value: "scram-sha-512"
               - name: STRIMZI_SECURITY_PROTOCOL 18
                 value: "SSL"

   1

   用于监视 KafkaTopic 资源的 topics Operator 的 OpenShift 命名空间。指定 Kafka 集群的命名空间。

   2

   用于发现并连接到 Kafka 集群中所有代理的 bootstrap 代理地址的主机和端口对。在服务器停机时，使用逗号分隔列表来指定两个或三个代理地址。

   3

   用于标识由 Topic Operator 管理的 KafkaTopic 资源的标签。这不一定是 Kafka 集群的名称。它可以是分配给 KafkaTopic 资源的标签。如果部署多个主题 Operator，则每个标签必须是唯一的。也就是说，操作员无法管理相同的资源。

   4

   连接到 ZooKeeper 集群的地址和端口对。这必须与 Kafka 集群使用的相同 ZooKeeper 集群。

   5

   ZooKeeper 会话超时，以毫秒为单位。默认值为 18000 (18 秒)。

   6

   定期协调之间的间隔（以毫秒为单位）。默认值为 120000 (2 分钟)。

   7

   从 Kafka 获取主题元数据时的尝试次数。每次尝试之间的时间都定义为 exponential backoff。由于分区或副本数，请考虑增加这个值。默认值为 6 次尝试。

   8

   打印日志记录消息的级别。您可以将级别设为 ERROR、WARNING、INFO、DEBUG 或 TRACE。

   9

   启用 TLS 支持与 Kafka 代理的加密通信。

   10

   （可选）JVM 运行 Topic Operator 使用的 Java 选项。

   11

   （可选）为 Topic Operator 设置的调试(-D)选项。

   12

   （可选）如果通过 STRIMZI_TLS_ENABLED 启用 TLS，则跳过信任存储证书的生成。如果启用了此环境变量，代理必须使用公共可信证书颁发机构作为其 TLS 证书。默认值为 false。

   13

   （可选）为 mutual TLS 身份验证生成密钥存储证书。把它设置为 false 会禁用使用 TLS 到 Kafka 代理的客户端验证。默认值是 true。

   14

   （可选）连接到 Kafka 代理时支持客户端身份验证的 SASL。默认值为 false。

   15

   （可选）用于客户端身份验证的 SASL 用户名。仅在通过 STRIMZI_SASL_ENABLED 启用 SASL 时强制强制。

   16

   （可选）客户端身份验证的 SASL 密码。仅在通过 STRIMZI_SASL_ENABLED 启用 SASL 时强制强制。

   17

   （可选）客户端身份验证的 SASL 机制。仅在通过 STRIMZI_SASL_ENABLED 启用 SASL 时强制强制。您可以将值设为 plain、scram-sha-256 或 scram-sha-512。

   18

   （可选）用于与 Kafka 代理通信的安全协议。默认值为 "PLAINTEXT"。您可以将值设为 PLAINTEXT、SSL、SASL_PLAINTEXT 或 SASL_SSL。

2. 如果要连接到使用公共证书颁发机构中的证书的 Kafka 代理，请将 STRIMZI_PUBLI_CA 设置为 true。将此属性设置为 true，例如，如果您使用 Amazon AWS MSK 服务。

3. 如果您使用 STRIMZI_TLS_ENABLED 环境变量启用了 TLS，请指定用于验证到 Kafka 集群连接的密钥存储和信任存储。

   TLS 配置示例

   # ....
   env:
     - name: STRIMZI_TRUSTSTORE_LOCATION 1
       value: "/path/to/truststore.p12"
     - name: STRIMZI_TRUSTSTORE_PASSWORD 2
       value: "TRUSTSTORE-PASSWORD"
     - name: STRIMZI_KEYSTORE_LOCATION 3
       value: "/path/to/keystore.p12"
     - name: STRIMZI_KEYSTORE_PASSWORD 4
       value: "KEYSTORE-PASSWORD"
   # ...

   1

   truststore 包含用来为 Kafka 和 ZooKeeper 服务器证书签名的证书颁发机构的公钥。

   2

   用于访问 truststore 的密码。

   3

   密钥存储包含 TLS 客户端身份验证的私钥。

   4

   用于访问密钥存储的密码。

4. 部署主题 Operator。

   oc create -f install/topic-operator

5. 检查部署的状态：

   oc get deployments

   输出显示了部署名称和就绪状态

   NAME                    READY  UP-TO-DATE  AVAILABLE
   strimzi-topic-operator  1/1    1           1

   READY 显示 ready/expected 的副本数量。当 AVAILABLE 输出显示为 1 时，部署成功。

流程

1. 编辑 install/user-operator/05-Deployment-strimzi-user-operator.yaml 独立部署文件中的以下 env 属性。

   独立用户 Operator 部署配置示例

   apiVersion: apps/v1
   kind: Deployment
   metadata:
     name: strimzi-user-operator
     labels:
       app: strimzi
   spec:
     # ...
     template:
       # ...
       spec:
         # ...
         containers:
           - name: strimzi-user-operator
             # ...
             env:
               - name: STRIMZI_NAMESPACE 1
                 valueFrom:
                   fieldRef:
                     fieldPath: metadata.namespace
               - name: STRIMZI_KAFKA_BOOTSTRAP_SERVERS 2
                 value: my-kafka-bootstrap-address:9092
               - name: STRIMZI_CA_CERT_NAME 3
                 value: my-cluster-clients-ca-cert
               - name: STRIMZI_CA_KEY_NAME 4
                 value: my-cluster-clients-ca
               - name: STRIMZI_LABELS 5
                 value: "strimzi.io/cluster=my-cluster"
               - name: STRIMZI_FULL_RECONCILIATION_INTERVAL_MS 6
                 value: "120000"
               - name: STRIMZI_LOG_LEVEL 7
                 value: INFO
               - name: STRIMZI_GC_LOG_ENABLED 8
                 value: "true"
               - name: STRIMZI_CA_VALIDITY 9
                 value: "365"
               - name: STRIMZI_CA_RENEWAL 10
                 value: "30"
               - name: STRIMZI_JAVA_OPTS 11
                 value: "-Xmx=512M -Xms=256M"
               - name: STRIMZI_JAVA_SYSTEM_PROPERTIES 12
                 value: "-Djavax.net.debug=verbose -DpropertyName=value"
               - name: STRIMZI_SECRET_PREFIX 13
                 value: "kafka-"
               - name: STRIMZI_ACLS_ADMIN_API_SUPPORTED 14
                 value: "true"
               - name: STRIMZI_MAINTENANCE_TIME_WINDOWS 15
                 value: '* * 8-10 * * ?;* * 14-15 * * ?'

   1

   用于监视 KafkaUser 资源的 User Operator 的 OpenShift 命名空间。只能指定一个命名空间。

   2

   用于发现并连接到 Kafka 集群中所有代理的 bootstrap 代理地址的主机和端口对。在服务器停机时，使用逗号分隔列表来指定两个或三个代理地址。

   3

   包含用于 TLS 客户端身份验证的新用户证书的证书颁发机构的公钥(ca.crt)值的 OpenShift Secret。

   4

   包含用于 TLS 客户端身份验证的新用户证书的证书颁发机构(ca.key)值的 OpenShift Secret。

   5

   用于标识由 User Operator 管理的 KafkaUser 资源的标签。这不一定是 Kafka 集群的名称。它可以是分配给 KafkaUser 资源的标签。如果部署多个用户 Operator，则每个标签必须是唯一的。也就是说，操作员无法管理相同的资源。

   6

   定期协调之间的间隔（以毫秒为单位）。默认值为 120000 (2 分钟)。

   7

   打印日志记录消息的级别。您可以将级别设为 ERROR、WARNING、INFO、DEBUG 或 TRACE。

   8

   启用垃圾回收(GC)日志记录。默认值是 true。

   9

   证书颁发机构的有效性周期。默认值为 365 天。

   10

   证书颁发机构的续订期。续订周期从当前证书的过期日期向后兼容。默认为 30 天，可在旧证书过期之前启动证书续订。

   11

   （可选）运行 User Operator 的 JVM 使用的 Java 选项

   12

   （可选）为 User Operator 设置的调试(-D)选项

   13

   （可选） 用于 User Operator 创建的 OpenShift secret 的名称的前缀。

   14

   （可选）指示 Kafka 集群是否支持使用 Kafka Admin API 管理授权 ACL 规则。当设置为 false 时，User Operator 将拒绝 具有简单 授权 ACL 规则的所有资源。这有助于避免 Kafka 集群日志中不必要的异常。默认值是 true。

   15

   （可选）Semi-colon 分离的 Cron 表达式列表，用于定义过期用户证书的维护时间窗口。

2. 如果使用 TLS 连接到 Kafka 集群，请指定用于验证连接的 secret。否则，转到下一步。

   TLS 配置示例

   # ....
   env:
     - name: STRIMZI_CLUSTER_CA_CERT_SECRET_NAME 1
       value: my-cluster-cluster-ca-cert
     - name: STRIMZI_EO_KEY_SECRET_NAME 2
       value: my-cluster-entity-operator-certs
   # ..."

   1

   OpenShift Secret 包括为 TLS 客户端验证签发 Kafka 代理的 Certificate Authority 的共钥 (ca.crt) 值。

   2

   包含密钥存储(entity-operator.p12)的 OpenShift Secret，其私钥和证书用于针对 Kafka 集群进行 TLS 身份验证。Secret 还必须包含用于访问密钥存储的密码(entity-operator.password)。

3. 部署 User Operator。

   oc create -f install/user-operator

4. 检查部署的状态：

   oc get deployments

   输出显示了部署名称和就绪状态

   NAME                   READY  UP-TO-DATE  AVAILABLE
   strimzi-user-operator  1/1    1           1

   READY 显示 ready/expected 的副本数量。当 AVAILABLE 输出显示为 1 时，部署成功。

流程

1. 通过在 .spec.build.output 中指定容器 registry 和 .spec. build.plugins 中的其他连接器来配置 KafkaConnect 自定义资源：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnect
   metadata:
     name: my-connect-cluster
   spec: 1
     #...
     build:
       output: 2
         type: docker
         image: my-registry.io/my-org/my-connect-cluster:latest
         pushSecret: my-registry-credentials
       plugins: 3
         - name: debezium-postgres-connector
           artifacts:
             - type: tgz
               url: https://repo1.maven.org/maven2/io/debezium/debezium-connector-postgres/1.3.1.Final/debezium-connector-postgres-1.3.1.Final-plugin.tar.gz
               sha512sum: 962a12151bdf9a5a30627eebac739955a4fd95a08d373b86bdcea2b4d0c27dd6e1edd5cb548045e115e33a9e69b1b2a352bee24df035a0447cb820077af00c03
         - name: camel-telegram
           artifacts:
             - type: tgz
               url: https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.7.0/camel-telegram-kafka-connector-0.7.0-package.tar.gz
               sha512sum: a9b1ac63e3284bea7836d7d24d84208c49cdf5600070e6bd1535de654f6920b74ad950d51733e8020bf4187870699819f54ef5859c7846ee4081507f48873479
     #...

   1

   Kafka Connect 集群的规格。

   2

   （必需）推送新镜像的容器注册表的配置。

   3

   （必需）连接器插件列表及其要添加到新容器镜像的工件。每个插件必须至少配置一个 工件。

2. 创建或更新资源：

   $ oc apply -f KAFKA-CONNECT-CONFIG-FILE

3. 等待新容器镜像构建，然后部署 Kafka Connect 集群。
4. 使用 Kafka Connect REST API 或 KafkaConnector 自定义资源使用您添加的连接器插件。

流程

1. 使用 registry.redhat.io/amq7/amq-streams-kafka-32-rhel8:2.2.2 作为基础镜像，创建一个新的 Dockerfile ：

   FROM registry.redhat.io/amq7/amq-streams-kafka-32-rhel8:2.2.2
   USER root:root
   COPY ./my-plugins/ /opt/kafka/plugins/
   USER 1001

   插件文件示例

   $ tree ./my-plugins/
   ./my-plugins/
   ├── debezium-connector-mongodb
   │   ├── bson-3.4.2.jar
   │   ├── CHANGELOG.md
   │   ├── CONTRIBUTE.md
   │   ├── COPYRIGHT.txt
   │   ├── debezium-connector-mongodb-0.7.1.jar
   │   ├── debezium-core-0.7.1.jar
   │   ├── LICENSE.txt
   │   ├── mongodb-driver-3.4.2.jar
   │   ├── mongodb-driver-core-3.4.2.jar
   │   └── README.md
   ├── debezium-connector-mysql
   │   ├── CHANGELOG.md
   │   ├── CONTRIBUTE.md
   │   ├── COPYRIGHT.txt
   │   ├── debezium-connector-mysql-0.7.1.jar
   │   ├── debezium-core-0.7.1.jar
   │   ├── LICENSE.txt
   │   ├── mysql-binlog-connector-java-0.13.0.jar
   │   ├── mysql-connector-java-5.1.40.jar
   │   ├── README.md
   │   └── wkb-1.0.2.jar
   └── debezium-connector-postgres
       ├── CHANGELOG.md
       ├── CONTRIBUTE.md
       ├── COPYRIGHT.txt
       ├── debezium-connector-postgres-0.7.1.jar
       ├── debezium-core-0.7.1.jar
       ├── LICENSE.txt
       ├── postgresql-42.0.0.jar
       ├── protobuf-java-2.6.1.jar
       └── README.md

   注意

   这个示例为 MongoDB、MySQL 和 PostgreSQL 使用 Debezium 连接器。在 Kafka Connect 中运行的 Debezium 与任何其他 Kafka Connect 任务相同。

2. 构建容器镜像。
3. 将自定义镜像推送到容器 registry。

4. 指向新的容器镜像。

   您可以：

   • 编辑 KafkaConnect 自定义资源的 KafkaConnect.spec.image 属性。

     如果设置，此属性会覆盖 Cluster Operator 中的 STRIMZI_KAFKA_CONNECT_IMAGES 变量。

     apiVersion: kafka.strimzi.io/v1beta2
     kind: KafkaConnect
     metadata:
       name: my-connect-cluster
     spec: 1
       #...
       image: my-new-container-image 2
       config: 3
         #...

     1

     Kafka Connect 集群的规格。

     2

     pod 的 docker 镜像。

     3

     配置 Kafka Connect worker （而非连接器）。

     或者

   • 在 install/cluster-operator/060-Deployment-strimzi-cluster-operator.yaml 文件中，编辑 STRIMZI_KAFKA_CONNECT_IMAGES 变量以指向新容器镜像，然后重新安装 Cluster Operator。