Flink sink到es8，有人实现了么，或者怎么能做下兼容呢？

Flink的Elasticsearch SQL Connector目前只支持Elasticsearch 7.x版本。如果你需要将数据同步到Elasticsearch 8.x版本，你可以考虑使用Flink的Elasticsearch 7.x版本的客户端库，

Flink Elasticsearch Sink连接器目前还未支持Elasticsearch 8。Flink为ElasticSearch专门提供了官方的Sink连接器，并且它支持写入到当前最新版本的ElasticSearch。然而，因为Elasticsearch 8与之前的版本在一些方面有所不同，例如序列化器（Serializer）的改变，所以直接使用Flink的官方Elasticsearch Sink可能会遇到兼容性问题。

对于这种情况，你可以尝试以下方法：

1. 自定义实现一个Elasticsearch Sink。你需要自行处理与Elasticsearch 8通信的细节，包括序列化和反序列化的问题。

2. 另一种可能的解决方案是继续使用Flink的Elasticsearch Sink，但是需要将你的Elasticsearch集群版本降级到7.x。这样可以避免由于版本不兼容导致的问题。

基于 AsyncSinkWriter 自己做一个，也比较简单，此回答整理自钉群“【③群】Apache Flink China社区”