Kafka Flink using Python

Question

我看不到太多关于kafka flink connector python API的信息。我开始知道它是测试版，我可以使用 python 使用 kafkaflink 连接器 API 吗？如果是，请向我建议此连接器的程序。 我还提到了 Apache Flink：Python 流 API 中的 Kafka 连接器，"无法加载用户类"。我也可以使用python API的滑动窗口的概念。

Answer 1

如果你坚持使用 Table API，Flink 1.9 中会有一些对 Python 的支持，在 1.10 版本中很快就会有更多支持。

滑动窗口通过 Flink 1.9 中的 Table API 与 Kafka 和 Python 配合使用。滑动窗口见这里，卡夫卡，看这里。