private boolean isUpsertKafkaConnector(Format format, boolean hasPrimaryKey) {
        if (format instanceof JsonFormat && hasPrimaryKey) {
            return true;
        } else if (format instanceof CsvFormat && hasPrimaryKey) {
            return true;
        } else {
            return format instanceof AvroFormat && hasPrimaryKey;
        }
    }
true is upsert kafka connector
false is kafka connector
@return Boolean variable that decides connector option
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/KafkaExtractNode.java