某公司在公司內部託管了一個 Apache Flink 應用程序。該應用程序處理來自多個 Apache Kafka 集羣的數據。公司已將其中一些數據源遷移到 AWS,現在希望遷移 Flink 應用程序。公司必須確保駐留在 VPC 內數據庫中的數據不會穿越互聯網。
A. 公司 VPC 內的 Amazon EC2 上實施 Flink 在 VPC 中創建 Amazon Managed Streaming for Apache Kafka(Amazon MSK)羣集,以收集來自 VPC 內應用程序和數據庫的數據 使用 Amazon Kinesis Data Streams 收集來自公共互聯網的數據 通過使用 AWS Client VPN 或 AWS Direct Connect,配置 Flink 以獲得來自 Kinesis Data Streams Amazon MSK 和任何內部部署的 Kafka 羣集的數據源
B. 公司 VPC 內的 Amazon EC2 上實施 Flink 使用 Amazon Kinesis Data Streams 收集來自 VPC 內應用程序和數據庫以及公共互聯網的數據 通過使用 AWS Client VPN 或 AWS Direct Connect,配置 Flink 以獲得來自 Kinesis Data Streams 和任何內部部署的 Kafka 集羣的數據源
C. 過上傳編譯的 Flink jar 文件創建 Amazon Kinesis Data Analytics 應用程序 使用 Amazon Kinesis Data Streams 收集來自 VPC 和公共互聯網內應用程序和數據庫的數據 通過使用 AWS Client VPN 或 AWS Direct Connect 配置 Kinesis Data Analytics 應用程序,使其擁有來自 Kinesis Data Streams 和任何內部部署 Kafka 集羣的數據源
D. 公司的 VPC 中創建 Amazon Managed Streaming for Apache Kafka(Amazon MSK)集羣,以收集來自 VPC 中的應用程序和數據庫的數據 使用 Amazon Kinesis Data Streams 收集來自公共互聯網的數據 配置 Kinesis Data Analytics 應用程序,使其具有來自 Kinesis Data Stream 的數據源
E. 過使用 AWS Client VPN 或 AWS Direct Connect,亞馬遜 MSK 和任何內部部署的 Kafka 集羣