@Override
    public String getPrimaryKey() {
        return primaryKey;
    }
if you want to set field routing, set the routing.field-name
The elasticsearch-6-inlong Connector is compatible with elasticsearch versions 5 and 6
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/ElasticsearchLoadNode.java