外部データベースの変更をKafkaへ取り込む｜AWS認定 Associate DEA-C01 試験オリジナル練習問題

1.1標準

外部データベースの変更イベントをKafkaトピックへ取り込みたい。

Kafka Connectのコネクタ管理を自前のEC2クラスタで行わず、MSKと統合する。

最も適切な構成はどれか。

ヒント1: ヒント

Kafka Connectのソースコネクタをマネージドに実行し、外部システムからKafkaトピックへ流す構成を考える。

ヒント2: 用語の確認

取り込み方式、容量、順序、再処理、配信先、運用責任の違いを整理する。

Amazon MSK Connectでソースコネクタを実行する: MSK ConnectはKafka Connectコネクタの実行・スケールを管理する。
Amazon Macieでデータベース変更をKafkaへ送る: Macieは保存データの機密情報検出を行う。
S3 Glacierへ変更を保存してKafkaが直接読む: S3 Glacierは長期保管と低頻度アクセスを目的とする。
CloudFormationだけで外部システムの変更を監視する: CloudFormationはインフラストラクチャをコードで管理するサービスである。

詳細解説

正しいAmazon MSK Connectでソースコネクタを実行する

Kafka Connectのコネクタをマネージドに実行し、外部システムからMSKトピックへデータを取り込める。

誤りAmazon Macieでデータベース変更をKafkaへ送る

MacieはS3上の機密情報検出サービスで、Kafka Connectコネクタを実行しない。

誤りS3 Glacierへ変更を保存してKafkaが直接読む

Glacierはアーカイブストレージで、低遅延のKafkaソースコネクタには向かない。

誤りCloudFormationだけで外部システムの変更を監視する

CloudFormationはリソースのプロビジョニングであり、外部DBの変更取得処理を実行しない。

一時的な検証環境で実行できる例です。

Amazon MSK Connectのコネクタ、ワーカー、ソースコネクタの公式説明を確認する。

Kafkaブローカー、コネクタ実行基盤、アーカイブ・監査サービスの役割を区別できる。

基礎のおさらい

コネクタは外部システムとの入出力を担当し、ブローカーはトピックの保持・配信を担当する。

ワーカー数、プラグイン、ネットワーク、認証情報を管理し、コネクタのスケールと障害を監視する。

問題IDAWS-DEA-019

確認環境AWS公式DEA-C01試験ガイドと各サービスの公式ドキュメントの確認

最終技術確認2026-08-20