flink-cdc 连接pulsar，读取pulsar数据请问有相关文档吗？
flink-cdc 连接pulsar，读取pulsar数据，flink1.12以下的版本用 pulsar-flink-connector_2.11.jar 这个jar包，可以读取pulsar里的对象、文件、图片、音视频流。 flink 1.12以上的版本用的是flink-connector-pulsar.jar 和 flink-sql-connector-pulsar.jar ， flink1.12版本的找不到例子，去读取pulsar里的对象、文件、图片、音视频流，请问有相关文档吗？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
北京阿里云ACE会长
对于Flink 1.12及以上版本，您可以使用Flink的官方Pulsar连接器（flink-connector-pulsar.jar和flink-sql-connector-pulsar.jar）来读取Pulsar中的数据。这些连接器提供了与Pulsar集成的功能，可以读取Pulsar的消息和事件。
然而，需要注意的是，Pulsar本身是一个消息队列和流处理平台，主要用于处理消息数据。它并不直接支持存储和处理大型二进制对象、文件、图片、音视频流等。因此，直接从Pulsar中读取这些类型的数据可能并不是最佳实践。
如果您想处理对象、文件、图片、音视频流等类型的数据，通常建议将这些数据存储在适合其类型的专用存储系统（如分布式文件系统、对象存储服务等）中，并在需要时从中读取数据进行处理。然后，您可以使用Flink的Pulsar连接器读取这些存储系统中的数据，并进行相应的处理。
2023-08-11 17:01:28赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。