Flink sink到es8，有人实现了么，或者怎么能做下兼容呢？
Flink sink到es8，有人实现了么，或者怎么能做下兼容呢？之前同步到es7，发现同步到es8报错着，官方到现在也不支持sink es8
写回答
-
面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。Flink的Elasticsearch SQL Connector目前只支持Elasticsearch 7.x版本。如果你需要将数据同步到Elasticsearch 8.x版本，你可以考虑使用Flink的Elasticsearch 7.x版本的客户端库，
2023-10-23 13:43:41赞同 展开评论 打赏 -
Flink Elasticsearch Sink连接器目前还未支持Elasticsearch 8。Flink为ElasticSearch专门提供了官方的Sink连接器，并且它支持写入到当前最新版本的ElasticSearch。然而，因为Elasticsearch 8与之前的版本在一些方面有所不同，例如序列化器（Serializer）的改变，所以直接使用Flink的官方Elasticsearch Sink可能会遇到兼容性问题。
对于这种情况，你可以尝试以下方法：
自定义实现一个Elasticsearch Sink。你需要自行处理与Elasticsearch 8通信的细节，包括序列化和反序列化的问题。
另一种可能的解决方案是继续使用Flink的Elasticsearch Sink，但是需要将你的Elasticsearch集群版本降级到7.x。这样可以避免由于版本不兼容导致的问题。
2023-10-23 11:00:17赞同 展开评论 打赏 -
基于 AsyncSinkWriter 自己做一个，也比较简单，此回答整理自钉群“【③群】Apache Flink China社区”
2023-10-23 08:07:01赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关文章
相关电子书
更多
