Flink 实时写入数据到 ElasticSearch 性能调优
线上业务反应使用 Flink 消费上游 kafka topic 里的轨迹数据出现 backpressure，数据积压严重。单次 bulk 的写入量为：3000/50mb/30s，并行度为 48。针对该问题，为了避免影响线上业务申请了一个与线上集群配置相同的 ES 集群。
笔记整理：数据处理方式Data Processing
1.批处理Batch Processing
定义：将任务成批地提交给系统，由系统自动完成后再输出结果。
举个例子，住在UIC新小镇的人去旧小镇上课，学校没造诺亚方舟，没办法哗啦一下送过去，只能用几辆大巴，将我们一批批送过去。
Flink-Kafka-Connector Flink结合Kafka实战
简介
Flink-kafka-connector用来做什么？
Kafka中的partition机制和Flink的并行度机制结合，实现数据恢复Kafka可以作为Flink的source和sink任务失败，通过设置kafka的offset来恢复应用
kafka简单介绍
关于kafka，我们会有专题文章介绍，这里简单介绍几个必须知道的概念。