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

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

• https://docs.aws.amazon.com/kinesisanalytics/latest/java/vpc.html
• https://docs.aws.amazon.com/kinesisanalytics/latest/java/example-msk.html