如何将Kinesis数据分析Flink应用程序与在Amazon EC2上运行的自管理Kafka集群集成(不是Amazon MSK)?

0

【以下的问题经过翻译处理】 用户希望构建一个实时应用程序,其中的数据存储在Kafka集群中。Kafka正在AWS上运行,不使用MSK而是使用K8S。如何将Kinesis数据分析Flink应用程序与Kafka集成所需的步骤是什么?

profile picture
エキスパート
質問済み 6ヶ月前30ビュー
1回答
0

【以下的回答经过翻译处理】 这和从Amazon MSK读取数据非常相似。使用Kinesis Data Analytics (KDA)从Kafka(或Amazon MSK)消费数据基本上意味着在代理和任务管理器之间建立网络连接。使用KDA,您可以启用VPC支持,以便将任务管理器的ENI暴露在您指定的子网中。如果您然后正确配置ENI的安全组,您的Flink应用程序应该能够连接到Kafka代理。请参阅以下参考文献:

profile picture
エキスパート
回答済み 6ヶ月前

ログインしていません。 ログイン 回答を投稿する。

優れた回答とは、質問に明確に答え、建設的なフィードバックを提供し、質問者の専門分野におけるスキルの向上を促すものです。

質問に答えるためのガイドライン

関連するコンテンツ