ある企業が、Apache Flinkアプリケーションを構内でホストしている。このアプリケーションは、複数の Apache Kafka クラスタからのデータを処理する。これらのソースのいくつかを AWS に移行し、今度は Flink アプリケーションを移行したい。同社は、VPC内のデータベースに存在するデータがインターネットを横断しないことを保証しなければならない。
A. VPC内のアプリケーションとデータベースから来るデータを収集するために、VPC内にAmazon Managed Streaming for Apache Kafka (Amazon MSK)クラスタを作成する。 公共インターネットから来るデータを収集するために、Amazon Kinesis Data Streamsを使用する。 AWS Client VPNまたはAWS Direct Connectを使用して、Kinesis Data Streams Amazon MSKとオンプレミスのKafkaクラスタからのソースを持つようにFlinkを構成する。
B. Amazon Kinesis Data Streamsを使用して、VPC内のアプリケーションとデータベース、およびパブリックインターネットから来るデータを収集する。 AWS Client VPNまたはAWS Direct Connectを使用して、Kinesis Data StreamsとオンプレミスのKafkaクラスタからのソースを持つようにFlinkを構成する。
C. コンパイル済みのFlink jarファイルをアップロードして、Amazon Kinesis Data Analyticsアプリケーションを作成する Amazon Kinesis Data Streamsを使用して、VPCおよびパブリックインターネット内のアプリケーションとデータベースからデータを収集する AWS Client VPNまたはAWS Direct Connectを使用して、Kinesis Data StreamsとオンプレミスのKafkaクラスタからのソースを持つようにKinesis Data Analyticsアプリケーションを構成する
D. コンパイルされたFlink jarファイルをアップロードして、Amazon Kinesis Data Analyticsアプリケーションを作成する。 VPC内のアプリケーションとデータベースから来るデータを収集するために、会社のVPC内にAmazon Managed Streaming for Apache Kafka (Amazon MSK)クラスタを作成する。 公共インターネットから来るデータを収集するために、Amazon Kinesis Data Streamsを使用する。 Kinesis Data Streamからのソースを持つように、Kinesis Data Analyticsアプリケーションを構成する。
E. AWS Client VPN または AWS Direct Connect を使用する Amazon MSK およびオンプレミスの Kafka クラスター