public void createClientTest() {
        clientConfig.put("cluster.name", "docker-cluster");
        clientConfig.put("xpack.security.user", "elastic:abc123");
        callBridge.createClient(clientConfig);
    }
Company: www.dtstack.com

@author zhufeng
@date 2020-06-19
elasticsearch5/elasticsearch5-sink/src/test/java/com/dtstack/flink/sql/sink/elasticsearch/ExtendES5ApiCallBridgeTest.java