홈
제품
Red Hat AMQ
7.6
Using AMQ Streams on OpenShift
Chapter 15. AMQ Streams resource upgrades

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

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"

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

Copy to Clipboard

Toggle word wrap

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.

Update the Kafka resource in an editor.
```
oc edit kafka my-cluster
```
```
oc edit kafka my-cluster
```
Copy to Clipboard Toggle word wrap

Replace:

apiVersion: kafka.strimzi.io/v1alpha1

apiVersion: kafka.strimzi.io/v1alpha1

Copy to Clipboard

Toggle word wrap

with:

apiVersion:kafka.strimzi.io/v1beta1

apiVersion:kafka.strimzi.io/v1beta1

Copy to Clipboard

Toggle word wrap

If the Kafka resource has:

Kafka.spec.topicOperator

Kafka.spec.topicOperator

Copy to Clipboard

Toggle word wrap

Replace it with:

Kafka.spec.entityOperator.topicOperator

Kafka.spec.entityOperator.topicOperator

Copy to Clipboard

Toggle word wrap

For example, replace:

spec:
  # ...
  topicOperator: {}

spec:
  # ...
  topicOperator: {}

Copy to Clipboard

Toggle word wrap

with:

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

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

Copy to Clipboard

Toggle word wrap

If present, move:

Kafka.spec.entityOperator.affinity

Kafka.spec.entityOperator.affinity

Copy to Clipboard

Toggle word wrap

Kafka.spec.entityOperator.tolerations

Kafka.spec.entityOperator.tolerations

Copy to Clipboard

Toggle word wrap

to:

Kafka.spec.entityOperator.template.pod.affinity

Kafka.spec.entityOperator.template.pod.affinity

Copy to Clipboard

Toggle word wrap

Kafka.spec.entityOperator.template.pod.tolerations

Kafka.spec.entityOperator.template.pod.tolerations

Copy to Clipboard

Toggle word wrap

For example, move:

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

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

Copy to Clipboard

Toggle word wrap

to:

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

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

Copy to Clipboard

Toggle word wrap

If present, move:

Kafka.spec.kafka.affinity

Kafka.spec.kafka.affinity

Copy to Clipboard

Toggle word wrap

Kafka.spec.kafka.tolerations

Kafka.spec.kafka.tolerations

Copy to Clipboard

Toggle word wrap

to:

Kafka.spec.kafka.template.pod.affinity

Kafka.spec.kafka.template.pod.affinity

Copy to Clipboard

Toggle word wrap

Kafka.spec.kafka.template.pod.tolerations

Kafka.spec.kafka.template.pod.tolerations

Copy to Clipboard

Toggle word wrap

For example, move:

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

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

Copy to Clipboard

Toggle word wrap

to:

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

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

Copy to Clipboard

Toggle word wrap

If present, move:

Kafka.spec.zookeeper.affinity

Kafka.spec.zookeeper.affinity

Copy to Clipboard

Toggle word wrap

Kafka.spec.zookeeper.tolerations

Kafka.spec.zookeeper.tolerations

Copy to Clipboard

Toggle word wrap

to:

Kafka.spec.zookeeper.template.pod.affinity

Kafka.spec.zookeeper.template.pod.affinity

Copy to Clipboard

Toggle word wrap

Kafka.spec.zookeeper.template.pod.tolerations

Kafka.spec.zookeeper.template.pod.tolerations

Copy to Clipboard

Toggle word wrap

For example, move:

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

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

Copy to Clipboard

Toggle word wrap

to:

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

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

Copy to Clipboard

Toggle word wrap

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.

Update the KafkaConnect resource in an editor.
```
oc edit kafkaconnect my-connect
```
```
oc edit kafkaconnect my-connect
```
Copy to Clipboard Toggle word wrap

Replace:

apiVersion: kafka.strimzi.io/v1alpha1

apiVersion: kafka.strimzi.io/v1alpha1

Copy to Clipboard

Toggle word wrap

with:

apiVersion:kafka.strimzi.io/v1beta1

apiVersion:kafka.strimzi.io/v1beta1

Copy to Clipboard

Toggle word wrap

If present, move:

KafkaConnect.spec.affinity

KafkaConnect.spec.affinity

Copy to Clipboard

Toggle word wrap

KafkaConnect.spec.tolerations

KafkaConnect.spec.tolerations

Copy to Clipboard

Toggle word wrap

to:

KafkaConnect.spec.template.pod.affinity

KafkaConnect.spec.template.pod.affinity

Copy to Clipboard

Toggle word wrap

KafkaConnect.spec.template.pod.tolerations

KafkaConnect.spec.template.pod.tolerations

Copy to Clipboard

Toggle word wrap

For example, move:

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

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

Copy to Clipboard

Toggle word wrap

to:

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

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

Copy to Clipboard

Toggle word wrap

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.

Update the KafkaConnectS2I resource in an editor.
```
oc edit kafkaconnects2i my-connect
```
```
oc edit kafkaconnects2i my-connect
```
Copy to Clipboard Toggle word wrap

Replace:

apiVersion: kafka.strimzi.io/v1alpha1

apiVersion: kafka.strimzi.io/v1alpha1

Copy to Clipboard

Toggle word wrap

with:

apiVersion:kafka.strimzi.io/v1beta1

apiVersion:kafka.strimzi.io/v1beta1

Copy to Clipboard

Toggle word wrap

If present, move:

KafkaConnectS2I.spec.affinity

KafkaConnectS2I.spec.affinity

Copy to Clipboard

Toggle word wrap

KafkaConnectS2I.spec.tolerations

KafkaConnectS2I.spec.tolerations

Copy to Clipboard

Toggle word wrap

to:

KafkaConnectS2I.spec.template.pod.affinity

KafkaConnectS2I.spec.template.pod.affinity

Copy to Clipboard

Toggle word wrap

KafkaConnectS2I.spec.template.pod.tolerations

KafkaConnectS2I.spec.template.pod.tolerations

Copy to Clipboard

Toggle word wrap

For example, move:

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

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

Copy to Clipboard

Toggle word wrap

to:

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

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

Copy to Clipboard

Toggle word wrap

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.

Update the KafkaMirrorMaker resource in an editor.
```
oc edit kafkamirrormaker my-connect
```
```
oc edit kafkamirrormaker my-connect
```
Copy to Clipboard Toggle word wrap

Replace:

apiVersion: kafka.strimzi.io/v1alpha1

apiVersion: kafka.strimzi.io/v1alpha1

Copy to Clipboard

Toggle word wrap

with:

apiVersion:kafka.strimzi.io/v1beta1

apiVersion:kafka.strimzi.io/v1beta1

Copy to Clipboard

Toggle word wrap

If present, move:

KafkaConnectMirrorMaker.spec.affinity

KafkaConnectMirrorMaker.spec.affinity

Copy to Clipboard

Toggle word wrap

KafkaConnectMirrorMaker.spec.tolerations

KafkaConnectMirrorMaker.spec.tolerations

Copy to Clipboard

Toggle word wrap

to:

KafkaConnectMirrorMaker.spec.template.pod.affinity

KafkaConnectMirrorMaker.spec.template.pod.affinity

Copy to Clipboard

Toggle word wrap

KafkaConnectMirrorMaker.spec.template.pod.tolerations

KafkaConnectMirrorMaker.spec.template.pod.tolerations

Copy to Clipboard

Toggle word wrap

For example, move:

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

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

Copy to Clipboard

Toggle word wrap

to:

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

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

Copy to Clipboard

Toggle word wrap

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.

Update the KafkaTopic resource in an editor.
```
oc edit kafkatopic my-topic
```
```
oc edit kafkatopic my-topic
```
Copy to Clipboard Toggle word wrap

Replace:

apiVersion: kafka.strimzi.io/v1alpha1

apiVersion: kafka.strimzi.io/v1alpha1

Copy to Clipboard

Toggle word wrap

with:

apiVersion:kafka.strimzi.io/v1beta1

apiVersion:kafka.strimzi.io/v1beta1

Copy to Clipboard

Toggle word wrap

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.

Update the KafkaUser resource in an editor.
```
oc edit kafkauser my-user
```
```
oc edit kafkauser my-user
```
Copy to Clipboard Toggle word wrap

Replace:

apiVersion: kafka.strimzi.io/v1alpha1

apiVersion: kafka.strimzi.io/v1alpha1

Copy to Clipboard

Toggle word wrap

with:

apiVersion:kafka.strimzi.io/v1beta1

apiVersion:kafka.strimzi.io/v1beta1

Copy to Clipboard

Toggle word wrap

Save the file, exit the editor and wait for the updated resource to be reconciled.

맨 위로 이동

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

Chapter 15. AMQ Streams resource upgrades

15.1. Upgrading Kafka resources
링크 복사

15.2. Upgrading Kafka Connect resources
링크 복사

15.3. Upgrading Kafka Connect S2I resources
링크 복사

15.4. Upgrading Kafka MirrorMaker resources
링크 복사

15.5. Upgrading Kafka Topic resources
링크 복사

15.6. Upgrading Kafka User resources
링크 복사

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

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

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

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

Chapter 15. AMQ Streams resource upgrades

15.1. Upgrading Kafka resources링크 복사링크가 클립보드에 복사되었습니다!

15.2. Upgrading Kafka Connect resources링크 복사링크가 클립보드에 복사되었습니다!

15.3. Upgrading Kafka Connect S2I resources링크 복사링크가 클립보드에 복사되었습니다!

15.4. Upgrading Kafka MirrorMaker resources링크 복사링크가 클립보드에 복사되었습니다!

15.5. Upgrading Kafka Topic resources링크 복사링크가 클립보드에 복사되었습니다!

15.6. Upgrading Kafka User resources링크 복사링크가 클립보드에 복사되었습니다!

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

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

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

15.1. Upgrading Kafka resources
링크 복사

15.2. Upgrading Kafka Connect resources
링크 복사

15.3. Upgrading Kafka Connect S2I resources
링크 복사

15.4. Upgrading Kafka MirrorMaker resources
링크 복사

15.5. Upgrading Kafka Topic resources
링크 복사

15.6. Upgrading Kafka User resources
링크 복사