概要
今回は、第一回で構築したConfluentのクラスタを利用しConfluent Control CenterにログインしてConfluent Replicator部分を確認してみたいと思います。
Confluent Control Centerにログイン
１.以下のURLでWebブラウザからコンフルエントコントロールセンターのGUIにアクセスします。
http://localhost:9021
Confluent Replicator は、コピー元 Kafka クラスターからコピー先 Kafka クラスターにデータをコピーします。コピー元とコピー先のクラスターは通常、異なるクラスターですが、このサンプルでは、コピー元とコピー先の Kafka クラスターは同じです。他のコンポーネントと同様に、Confluent Replicator にもセキュリティが構成されています。
１.Confluent Control Center(以下CCC) で、Replicator のステータスとスループットを表示します。
2.CCCのメニューにある「Consumers」を選択し、Confluent Replicator のスループットとレイテンシをモニタリングします。Replicator は Kafka Connect ソースコネクターであり対応するコンシューマーグループはconnect-replicator です。
３.Replicatorのコンシューマーラグを表示します。
４.Replicator の消費メトリクスを表示します。
５.CCCのメニューにある「Connect」を選択し、Settingsで右上の一時停止アイコンを押し、有効になるまで10秒間待ってReplicatorコネクターを一時停止します。これで、関連するコンシューマーグループの消費が停止します。
６.「connect-replicator」コンシューマーグループの消費が停止したのをCCCで確認します。
７.5.で一時停止したReplicatorコネクターを再起動します。
８.「connect-replicator」コンシューマーグループが消費を再開したことを確認します。ここでは以下の確認ができます。
・コンシューマーグループ「connect-replicator」が動作していなかった時間があるにもかかわらず、すべてのメッセージが配信済みとして表示されます。
・レイテンシはピークに達した後、徐々に減少します。これは生成したタイムスタンプに対して相対的であるためです。
今回も最後までお読み頂きありがとうございました！