Red Hat Summit Red Hat Summit지원콘솔개발자평가판 시작연락처

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 15. AMQ Streams resource upgrades

For this release of AMQ Streams, resources that use the API version kafka.strimzi.io/v1alpha1 must be updated to use kafka.strimzi.io/v1beta1.

The kafka.strimzi.io/v1alpha1 API version is deprecated.

This section describes the upgrade steps for the resources.

Important

The upgrade of resources must be performed after upgrading the Cluster Operator, so the Cluster Operator can understand the resources.

What if the resource upgrade does not take effect?

If the upgrade does not take effect, a warning is given in the logs on reconciliation to indicate that the resource cannot be updated until the apiVersion is updated.

To trigger the update, make a cosmetic change to the custom resource, such as adding an annotation.

Example annotation: 

metadata:
  # ...
  annotations:
    upgrade: "Upgraded to kafka.strimzi.io/v1beta1"

15.1. Upgrading Kafka resources
링크 복사

Prerequisites

  • A Cluster Operator supporting the v1beta1 API version is up and running.

Procedure

Execute the following steps for each Kafka resource in your deployment.

  1. Update the Kafka resource in an editor. 

    oc edit kafka my-cluster

  2. Replace: 

    apiVersion: kafka.strimzi.io/v1alpha1

    with: 

    apiVersion:kafka.strimzi.io/v1beta1

  3. If the Kafka resource has: 

    Kafka.spec.topicOperator

    Replace it with: 

    Kafka.spec.entityOperator.topicOperator

    For example, replace: 

    spec:
  # ...
  topicOperator: {}

    with: 

    spec:
  # ...
  entityOperator:
    topicOperator: {}

  4. If present, move: 

    Kafka.spec.entityOperator.affinity
     
    Kafka.spec.entityOperator.tolerations

    to: 

    Kafka.spec.entityOperator.template.pod.affinity
     
    Kafka.spec.entityOperator.template.pod.tolerations

    For example, move: 

    spec:
  # ...
  entityOperator:
    affinity {}
    tolerations {}

    to: 

    spec:
  # ...
  entityOperator:
    template:
      pod:
        affinity {}
        tolerations {}

  5. If present, move: 

    Kafka.spec.kafka.affinity
     
    Kafka.spec.kafka.tolerations

    to: 

    Kafka.spec.kafka.template.pod.affinity
     
    Kafka.spec.kafka.template.pod.tolerations

    For example, move: 

    spec:
  # ...
  kafka:
    affinity {}
    tolerations {}

    to: 

    spec:
  # ...
  kafka:
    template:
      pod:
        affinity {}
        tolerations {}

  6. If present, move: 

    Kafka.spec.zookeeper.affinity
     
    Kafka.spec.zookeeper.tolerations

    to: 

    Kafka.spec.zookeeper.template.pod.affinity
     
    Kafka.spec.zookeeper.template.pod.tolerations

    For example, move: 

    spec:
  # ...
  zookeeper:
    affinity {}
    tolerations {}

    to: 

    spec:
  # ...
  zookeeper:
    template:
      pod:
        affinity {}
        tolerations {}
  7. Save the file, exit the editor and wait for the updated resource to be reconciled.

15.2. Upgrading Kafka Connect resources
링크 복사

Prerequisites

  • A Cluster Operator supporting the v1beta1 API version is up and running.

Procedure

Execute the following steps for each KafkaConnect resource in your deployment.

  1. Update the KafkaConnect resource in an editor. 

    oc edit kafkaconnect my-connect

  2. Replace: 

    apiVersion: kafka.strimzi.io/v1alpha1

    with: 

    apiVersion:kafka.strimzi.io/v1beta1

  3. If present, move: 

    KafkaConnect.spec.affinity
     
    KafkaConnect.spec.tolerations

    to: 

    KafkaConnect.spec.template.pod.affinity
     
    KafkaConnect.spec.template.pod.tolerations

    For example, move: 

    spec:
  # ...
  affinity {}
  tolerations {}

    to: 

    spec:
  # ...
  template:
    pod:
      affinity {}
      tolerations {}
  4. Save the file, exit the editor and wait for the updated resource to be reconciled.

15.3. Upgrading Kafka Connect S2I resources
링크 복사

Prerequisites

  • A Cluster Operator supporting the v1beta1 API version is up and running.

Procedure

Execute the following steps for each KafkaConnectS2I resource in your deployment.

  1. Update the KafkaConnectS2I resource in an editor. 

    oc edit kafkaconnects2i my-connect

  2. Replace: 

    apiVersion: kafka.strimzi.io/v1alpha1

    with: 

    apiVersion:kafka.strimzi.io/v1beta1

  3. If present, move: 

    KafkaConnectS2I.spec.affinity
     
    KafkaConnectS2I.spec.tolerations

    to: 

    KafkaConnectS2I.spec.template.pod.affinity
     
    KafkaConnectS2I.spec.template.pod.tolerations

    For example, move: 

    spec:
  # ...
  affinity {}
  tolerations {}

    to: 

    spec:
  # ...
  template:
    pod:
      affinity {}
      tolerations {}
  4. Save the file, exit the editor and wait for the updated resource to be reconciled.

15.4. Upgrading Kafka MirrorMaker resources
링크 복사

Prerequisites

  • A Cluster Operator supporting the v1beta1 API version is up and running.

Procedure

Execute the following steps for each KafkaMirrorMaker resource in your deployment.

  1. Update the KafkaMirrorMaker resource in an editor. 

    oc edit kafkamirrormaker my-connect

  2. Replace: 

    apiVersion: kafka.strimzi.io/v1alpha1

    with: 

    apiVersion:kafka.strimzi.io/v1beta1

  3. If present, move: 

    KafkaConnectMirrorMaker.spec.affinity
     
    KafkaConnectMirrorMaker.spec.tolerations

    to: 

    KafkaConnectMirrorMaker.spec.template.pod.affinity
     
    KafkaConnectMirrorMaker.spec.template.pod.tolerations

    For example, move: 

    spec:
  # ...
  affinity {}
  tolerations {}

    to: 

    spec:
  # ...
  template:
    pod:
      affinity {}
      tolerations {}
  4. Save the file, exit the editor and wait for the updated resource to be reconciled.

15.5. Upgrading Kafka Topic resources
링크 복사

Prerequisites

  • A Topic Operator supporting the v1beta1 API version is up and running.

Procedure

Execute the following steps for each KafkaTopic resource in your deployment.

  1. Update the KafkaTopic resource in an editor. 

    oc edit kafkatopic my-topic

  2. Replace: 

    apiVersion: kafka.strimzi.io/v1alpha1

    with: 

    apiVersion:kafka.strimzi.io/v1beta1
  3. Save the file, exit the editor and wait for the updated resource to be reconciled.

15.6. Upgrading Kafka User resources
링크 복사

Prerequisites

  • A User Operator supporting the v1beta1 API version is up and running.

Procedure

Execute the following steps for each KafkaUser resource in your deployment.

  1. Update the KafkaUser resource in an editor. 

    oc edit kafkauser my-user

  2. Replace: 

    apiVersion: kafka.strimzi.io/v1alpha1

    with: 

    apiVersion:kafka.strimzi.io/v1beta1
  3. Save the file, exit the editor and wait for the updated resource to be reconciled.
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2026 Red Hat맨 위로 이동