问题1:大佬们，flink CDC支持pyflink吗？我用python 3.8, flink 1.14.4，flink cdc 2.2.1时，读不到mysql binlog
问题2:就是卡住不动，ctrl+c停止程序报这样的错误，大佬知道为啥吗？
大佬们，flink CDC支持pyflink吗？我用python 3.8, flink 1.14.4[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
=====这是一个广告位，招租中，联系qq 78315851====
Flink CDC 目前不直接支持 PyFlink（Python 版本的 Flink）。Flink CDC 是基于 Java 编写的，主要用于在 Flink 的 Java 和 Scala API 中实现 Change Data Capture 功能。
然而，您仍然可以在 PyFlink 环境中使用 Flink CDC。一种常见的做法是使用 PyFlink 的 Table API 或 DataStream API 与 Java 或 Scala 的 Flink CDC 进行集成。
具体而言，您可以使用 Java 或 Scala 开发一个 Flink CDC 应用程序，将变更数据发送到 Kafka、RocketMQ 或其他消息队列中。然后，您可以在 PyFlink 中消费这些变更数据，并进行相应的处理和分析。
为了实现这种集成，您需要：
1. 使用 Java 或 Scala 编写 Flink CDC 应用程序，将 CDC 数据发送到消息队列。 2. 在 PyFlink 中编写相应的代码来消费消息队列中的变更数据，并使用 PyFlink 的功能进行处理和分析。
请注意，此方法涉及跨语言和跨平台的集成，需要合理配置和管理相关组件，并确保版本兼容性。另外，跨语言和跨平台的集成可能会增加一些复杂性和维护成本。
回答1:支持的啊
回答2:
，此回答整理自钉群“Flink CDC 社区”