网站介绍：文章浏览阅读1k次。在使用Flink进行数据的处理的时候，一个必要步骤就是需要将计算的结果进行存储或导出，Flink中这个过程称为Sink，官方我们提供了常用的几种Sink Connector，例如:这篇就选取其中一个常用的ElasticsearchSink来进行介绍，并讲解一下生产环境中使用时的一些注意点，以及其内部实现机制。 根据自己所用的filnk版本以及es版本对上面的版本号进行调整 c、扩展配置 经过上面的代码已经实现了一个基础版的EsSink，但是上述代码当ES集群出现波动的时候，由于不具备重试机制则有可能出_flink写入es按照主键写入
- 链接地址：https://blog.csdn.net/weixin_43813200/article/details/125923549
- 链接标题：Flink写入数据到ElasticSearch (ElasticSearch详细使用指南及采坑记录)_flink写入es按照主键写入-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：5375
- 网站标签：flink写入es按照主键写入
