2.4.10. Kafka MirrorMaker 2.0 コネクタータスクの再起動の実行

手順

1. 再起動する Kafka MirrorMaker 2.0 コネクターを制御する KafkaMirrorMaker2 カスタムリソースの名前を見つけます。

   oc get KafkaMirrorMaker2

   Copy to Clipboard Toggle word wrap

2. Kafka MirrorMaker 2.0 コネクターの名前と、KafkaMirrorMaker2 カスタムリソースから再起動されるタスクの ID を検索します。タスク ID は 0 から始まる負の値ではない整数です。

   oc describe KafkaMirrorMaker2 KAFKAMIRRORMAKER-2-NAME

   Copy to Clipboard Toggle word wrap

3. コネクタータスクを再起動するには、OpenShift で KafkaMirrorMaker2 リソースにアノテーションを付けます。この例では、oc annotate は my-source->my-target.MirrorSourceConnector という名前のコネクタのタスク 0 を再起動します。

   oc annotate KafkaMirrorMaker2 KAFKAMIRRORMAKER-2-NAME "strimzi.io/restart-connector-task=my-source->my-target.MirrorSourceConnector:0"

   Copy to Clipboard Toggle word wrap

4. 次の調整が発生するまで待ちます (デフォルトでは 2 分ごとです)。

   アノテーションが調整プロセスで検出されれば、Kafka MirrorMaker 2.0 コネクタータスクは再起動されます。再起動タスクの要求が受け入れられると、KafkaMirrorMaker2 のカスタムリソースからアノテーションが削除されます。