public void checkDorisTableKey()

in src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java [77:86]

• 10 lines of code
• 4 McCabe index (conditional complexity)

    public void checkDorisTableKey(String tableName) {
        if (dorisOptions.enable2PC()
                && !dorisOptions.force2PC()
                && RestService.isUniqueKeyType(dorisOptions, tableName, LOG)) {
            LOG.info(
                    "The {} table type is unique model, the two phase commit default value should be disabled.",
                    tableName);
            dorisOptions.setEnable2PC(false);
        }
    }