第15章 AMQ Streams リソースのアップグレード
本リリースの AMQ Streams では、API バージョン kafka.strimzi.io/v1alpha1 を使用するリソースを更新して kafka.strimzi.io/v1beta1 を使用するようにする必要があります。
kafka.strimzi.io/v1alpha1 API バージョンは非推奨になりました。
ここでは、リソースのアップグレード手順を説明します。
リソースのアップグレードは、Cluster Operator をアップグレードしてから実施する 必要 があります。これにより、Cluster Operator がリソースを認識できるようになります。
リソースのアップグレードが実施されない場合
アップグレードが実施されない場合、apiVersion を更新するまでリソースを更新できないことを示す警告が、調整に関するログに記録されます。
更新をトリガーするには、カスタムリソースにアノテーション追加などの表面的な変更を加えます。
アノテーションの例:
metadata:
# ...
annotations:
upgrade: "Upgraded to kafka.strimzi.io/v1beta1"
metadata:
# ...
annotations:
upgrade: "Upgraded to kafka.strimzi.io/v1beta1"
15.1. Kafka リソースのアップグレード リンクのコピーリンクがクリップボードにコピーされました!
前提条件
-
v1beta1API バージョンをサポートする Cluster Operator が稼働している必要があります。
手順
デプロイメントの Kafka リソースごとに以下の手順を実行します。
エディターで
Kafkaリソースを更新します。oc edit kafka my-cluster
oc edit kafka my-clusterCopy to Clipboard Copied! Toggle word wrap Toggle overflow 以下の行を見つけます。
apiVersion: kafka.strimzi.io/v1alpha1
apiVersion: kafka.strimzi.io/v1alpha1Copy to Clipboard Copied! Toggle word wrap Toggle overflow この行を以下の行に変更します。
apiVersion:kafka.strimzi.io/v1beta1
apiVersion:kafka.strimzi.io/v1beta1Copy to Clipboard Copied! Toggle word wrap Toggle overflow Kafkaリソースに以下があるか確認します。Kafka.spec.topicOperator
Kafka.spec.topicOperatorCopy to Clipboard Copied! Toggle word wrap Toggle overflow ある場合は以下に変更します。
Kafka.spec.entityOperator.topicOperator
Kafka.spec.entityOperator.topicOperatorCopy to Clipboard Copied! Toggle word wrap Toggle overflow たとえば、以下がある場合を考えてみましょう。
spec: # ... topicOperator: {}spec: # ... topicOperator: {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow この行を以下の行に変更します。
spec: # ... entityOperator: topicOperator: {}spec: # ... entityOperator: topicOperator: {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow 以下があるか確認します。
Kafka.spec.entityOperator.affinity
Kafka.spec.entityOperator.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow Kafka.spec.entityOperator.tolerations
Kafka.spec.entityOperator.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow あれば以下に変更します。
Kafka.spec.entityOperator.template.pod.affinity
Kafka.spec.entityOperator.template.pod.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow Kafka.spec.entityOperator.template.pod.tolerations
Kafka.spec.entityOperator.template.pod.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow たとえば、以下の場合を考えてみましょう。
spec: # ... entityOperator: affinity {} tolerations {}spec: # ... entityOperator: affinity {} tolerations {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow これを以下に変更します。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 以下があるか確認します。
Kafka.spec.kafka.affinity
Kafka.spec.kafka.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow Kafka.spec.kafka.tolerations
Kafka.spec.kafka.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow あれば以下に変更します。
Kafka.spec.kafka.template.pod.affinity
Kafka.spec.kafka.template.pod.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow Kafka.spec.kafka.template.pod.tolerations
Kafka.spec.kafka.template.pod.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow たとえば、以下の場合を考えてみましょう。
spec: # ... kafka: affinity {} tolerations {}spec: # ... kafka: affinity {} tolerations {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow これを以下に変更します。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 以下があるか確認します。
Kafka.spec.zookeeper.affinity
Kafka.spec.zookeeper.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow Kafka.spec.zookeeper.tolerations
Kafka.spec.zookeeper.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow あれば以下に変更します。
Kafka.spec.zookeeper.template.pod.affinity
Kafka.spec.zookeeper.template.pod.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow Kafka.spec.zookeeper.template.pod.tolerations
Kafka.spec.zookeeper.template.pod.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow たとえば、以下の場合を考えてみましょう。
spec: # ... zookeeper: affinity {} tolerations {}spec: # ... zookeeper: affinity {} tolerations {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow これを以下に変更します。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow - ファイルを保存し、エディターを終了して更新したリソースが調整されるのを待ちます。
15.2. Kafka Connect リソースのアップグレード リンクのコピーリンクがクリップボードにコピーされました!
前提条件
-
v1beta1API バージョンをサポートする Cluster Operator が稼働している必要があります。
手順
デプロイメントの KafkaConnect リソースごとに以下の手順を実行します。
エディターで
KafkaConnectリソースを更新します。oc edit kafkaconnect my-connect
oc edit kafkaconnect my-connectCopy to Clipboard Copied! Toggle word wrap Toggle overflow 以下の行を見つけます。
apiVersion: kafka.strimzi.io/v1alpha1
apiVersion: kafka.strimzi.io/v1alpha1Copy to Clipboard Copied! Toggle word wrap Toggle overflow この行を以下の行に変更します。
apiVersion:kafka.strimzi.io/v1beta1
apiVersion:kafka.strimzi.io/v1beta1Copy to Clipboard Copied! Toggle word wrap Toggle overflow 以下があるか確認します。
KafkaConnect.spec.affinity
KafkaConnect.spec.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow KafkaConnect.spec.tolerations
KafkaConnect.spec.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow あれば以下に変更します。
KafkaConnect.spec.template.pod.affinity
KafkaConnect.spec.template.pod.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow KafkaConnect.spec.template.pod.tolerations
KafkaConnect.spec.template.pod.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow たとえば、以下の場合を考えてみましょう。
spec: # ... affinity {} tolerations {}spec: # ... affinity {} tolerations {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow これを以下に変更します。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow - ファイルを保存し、エディターを終了して更新したリソースが調整されるのを待ちます。
15.3. Kafka Connect S2I リソースのアップグレード リンクのコピーリンクがクリップボードにコピーされました!
前提条件
-
v1beta1API バージョンをサポートする Cluster Operator が稼働している必要があります。
手順
デプロイメントの KafkaConnectS2I リソースごとに以下の手順を実行します。
エディターで
KafkaConnectS2Iリソースを更新します。oc edit kafkaconnects2i my-connect
oc edit kafkaconnects2i my-connectCopy to Clipboard Copied! Toggle word wrap Toggle overflow 以下の行を見つけます。
apiVersion: kafka.strimzi.io/v1alpha1
apiVersion: kafka.strimzi.io/v1alpha1Copy to Clipboard Copied! Toggle word wrap Toggle overflow この行を以下の行に変更します。
apiVersion:kafka.strimzi.io/v1beta1
apiVersion:kafka.strimzi.io/v1beta1Copy to Clipboard Copied! Toggle word wrap Toggle overflow 以下があるか確認します。
KafkaConnectS2I.spec.affinity
KafkaConnectS2I.spec.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow KafkaConnectS2I.spec.tolerations
KafkaConnectS2I.spec.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow あれば以下に変更します。
KafkaConnectS2I.spec.template.pod.affinity
KafkaConnectS2I.spec.template.pod.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow KafkaConnectS2I.spec.template.pod.tolerations
KafkaConnectS2I.spec.template.pod.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow たとえば、以下の場合を考えてみましょう。
spec: # ... affinity {} tolerations {}spec: # ... affinity {} tolerations {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow これを以下に変更します。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow - ファイルを保存し、エディターを終了して更新したリソースが調整されるのを待ちます。
15.4. Kafka MirrorMaker リソースのアップグレード リンクのコピーリンクがクリップボードにコピーされました!
前提条件
-
v1beta1API バージョンをサポートする Cluster Operator が稼働している必要があります。
手順
デプロイメントの KafkaMirrorMaker リソースごとに以下の手順を実行します。
エディターで
KafkaMirrorMakerリソースを更新します。oc edit kafkamirrormaker my-connect
oc edit kafkamirrormaker my-connectCopy to Clipboard Copied! Toggle word wrap Toggle overflow 以下の行を見つけます。
apiVersion: kafka.strimzi.io/v1alpha1
apiVersion: kafka.strimzi.io/v1alpha1Copy to Clipboard Copied! Toggle word wrap Toggle overflow この行を以下の行に変更します。
apiVersion:kafka.strimzi.io/v1beta1
apiVersion:kafka.strimzi.io/v1beta1Copy to Clipboard Copied! Toggle word wrap Toggle overflow 以下があるか確認します。
KafkaConnectMirrorMaker.spec.affinity
KafkaConnectMirrorMaker.spec.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow KafkaConnectMirrorMaker.spec.tolerations
KafkaConnectMirrorMaker.spec.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow あれば以下に変更します。
KafkaConnectMirrorMaker.spec.template.pod.affinity
KafkaConnectMirrorMaker.spec.template.pod.affinityCopy to Clipboard Copied! Toggle word wrap Toggle overflow KafkaConnectMirrorMaker.spec.template.pod.tolerations
KafkaConnectMirrorMaker.spec.template.pod.tolerationsCopy to Clipboard Copied! Toggle word wrap Toggle overflow たとえば、以下の場合を考えてみましょう。
spec: # ... affinity {} tolerations {}spec: # ... affinity {} tolerations {}Copy to Clipboard Copied! Toggle word wrap Toggle overflow これを以下に変更します。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow - ファイルを保存し、エディターを終了して更新したリソースが調整されるのを待ちます。
15.5. Kafka Topic リソースのアップグレード リンクのコピーリンクがクリップボードにコピーされました!
前提条件
-
v1beta1API バージョンをサポートする Topic Operator が稼働している必要があります。
手順
デプロイメントの KafkaTopic リソースごとに以下の手順を実行します。
エディターで
KafkaTopicリソースを更新します。oc edit kafkatopic my-topic
oc edit kafkatopic my-topicCopy to Clipboard Copied! Toggle word wrap Toggle overflow 以下の行を見つけます。
apiVersion: kafka.strimzi.io/v1alpha1
apiVersion: kafka.strimzi.io/v1alpha1Copy to Clipboard Copied! Toggle word wrap Toggle overflow この行を以下の行に変更します。
apiVersion:kafka.strimzi.io/v1beta1
apiVersion:kafka.strimzi.io/v1beta1Copy to Clipboard Copied! Toggle word wrap Toggle overflow - ファイルを保存し、エディターを終了して更新したリソースが調整されるのを待ちます。
15.6. Kafka User リソースのアップグレード リンクのコピーリンクがクリップボードにコピーされました!
前提条件
-
v1beta1API バージョンをサポートする User Operator が稼働している必要があります。
手順
デプロイメントの KafkaUser リソースごとに以下の手順を実行します。
エディターで
KafkaUserリソースを更新します。oc edit kafkauser my-user
oc edit kafkauser my-userCopy to Clipboard Copied! Toggle word wrap Toggle overflow 以下の行を見つけます。
apiVersion: kafka.strimzi.io/v1alpha1
apiVersion: kafka.strimzi.io/v1alpha1Copy to Clipboard Copied! Toggle word wrap Toggle overflow この行を以下の行に変更します。
apiVersion:kafka.strimzi.io/v1beta1
apiVersion:kafka.strimzi.io/v1beta1Copy to Clipboard Copied! Toggle word wrap Toggle overflow - ファイルを保存し、エディターを終了して更新したリソースが調整されるのを待ちます。