Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4675 @rmetzger @tzulitai I create this PR and try to fix [https://issues.apache.org/jira/browse/FLINK-7386(https://issues.apache.org/jira/browse/FLINK-7386). In the PR I do some things as follows: 1. Add `createRequestIndex` method in `ElasticsearchApiCallBridge`, then we can use this method to create different `RequestIndexer` instance. 2. Add flink-connector-elasticsearch5.3 project and create `BulkProcessorIndexer`. `ActionRequest` will be converted to `DocWriteRequest` in the `BulkProcessorIndexer` in the project. What do you think? Please have a look when you're free, thanks
---