我正在尝试用Python中的Flink 1.13版本构建一个使用Kinesis数据分析的流应用程序。
应用程序的源是Kinesis数据流。
但是我可以看到Kinesis连接器FlinkKinesisConsumer在Flink1.13（PyFlink）版本中不可用。
是否有其他方法可以使用Python数据流API（使用Flink 1.13版本）连接Kinesis数据流？
我正在尝试用Python中的Flink 1.13版本构建一个使用Kinesis数据分析的流应用程序。
应用程序的源是Kinesis数据流。
但是我可以看到Kinesis连接器FlinkKinesisConsumer在Flink1.13（PyFlink）版本中不可用。
是否有其他方法可以使用Python数据流API（使用Flink 1.13版本）连接Kinesis数据流？
1条答案
按热度按时间laik7k3q1#
如果您在本地运行Flink（不是Kinesis Data Analytics的一部分），您可以从Maven下载连接器：https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-kinesis
目前，AWS支持的最新Flink版本所需的连接器版本为1.13.2版scala 2.12版。
为了方便Flink应用程序的开发，AWS还提供了Kinesis Data Analytics Studio，它提供了一个Apache Zeppelin笔记本环境。https://www.youtube.com/watch?v=SX_6x_wXIfA