2.4.5. Kafka MirrorMaker 2.0 コネクターの再起動の実行
この手順では、OpenShift アノテーションを使用して Kafka MirrorMaker 2.0 コネクターの再起動を手動でトリガーする方法を説明します。
前提条件
- Cluster Operator が稼働している必要があります。
手順
再起動する Kafka MirrorMaker 2.0 コネクターを制御する
KafkaMirrorMaker2
カスタムリソースの名前を見つけます。Copy to Clipboard Copied! Toggle word wrap Toggle overflow oc get KafkaMirrorMaker2
oc get KafkaMirrorMaker2
KafkaMirrorMaker2
カスタムリソースから再起動される Kafka MirrorMaker 2.0 コネクターの名前を見つけます。Copy to Clipboard Copied! Toggle word wrap Toggle overflow oc describe KafkaMirrorMaker2 KAFKAMIRRORMAKER-2-NAME
oc describe KafkaMirrorMaker2 KAFKAMIRRORMAKER-2-NAME
コネクターを再起動するには、OpenShift で
KafkaMirrorMaker2
リソースにアノテーションを付けます。この例では、oc annotate
はmy-source->my-target.MirrorSourceConnector
という名前のコネクターを再起動します。Copy to Clipboard Copied! Toggle word wrap Toggle overflow oc annotate KafkaMirrorMaker2 KAFKAMIRRORMAKER-2-NAME "strimzi.io/restart-connector=my-source->my-target.MirrorSourceConnector"
oc annotate KafkaMirrorMaker2 KAFKAMIRRORMAKER-2-NAME "strimzi.io/restart-connector=my-source->my-target.MirrorSourceConnector"
次の調整が発生するまで待ちます (デフォルトでは 2 分ごとです)。
アノテーションが調整プロセスで検出されれば、Kafka MirrorMaker 2.0 コネクターは再起動されます。再起動要求が許可されると、アノテーションは
KafkaMirrorMaker2
カスタムリソースから削除されます。