我们在 Flink 作业中使用了 flink(1.16) 包的 Flink kinesis 连接器库。现在我们计划迁移到 Flink 1.17,但我看到 flink-kinesis-connector 包已从 Flink-1.17 中删除。我们的 Flink 工作是引用多个类的 flink-kinesis-connector 包。谁能告诉我 flink-kinesis-connector 包的替代实现是什么。
自 Flink 1.17 以来,大多数 Flink 连接器已被外部化,这可能就是您无法直接看到它们的原因。连接器仍然存在,只是版本号不同,正如您可以在 Flink Kinesis 连接器的文档页面中看到的那样:https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/连接器/datastream/kinesis/ - 在撰写此答案时,最新版本是 4.1.0-1.17