public void createIndex(String indexName) throws Exception {
        final String url = esConfig.getOneHttpUrl() + InlongConstants.SLASH + indexName;
        ElasticsearchCreateIndexResponse response = HttpUtils.request(esConfig.getRestClient(), url, HttpMethod.PUT,
                null, getHttpHeaders(), ElasticsearchCreateIndexResponse.class);
        LOG.info("create es index:{} result: {}", indexName, response.getAcknowledged());
    }
Create index by REST API.

@param indexName elasticsearch index name
@throws IOException any IOException if occurred
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/es/ElasticsearchApi.java