public static String getMigrationsDir(
      final String configFilePath,
      final MigrationConfig config
  ) {
    final String migrationsDir = config.getString(MigrationConfig.KSQL_MIGRATIONS_DIR_OVERRIDE);
    if (migrationsDir != null && !migrationsDir.isEmpty()) {
      return migrationsDir;
    } else {
      return getMigrationsDirFromConfigFile(configFilePath);
    }
  }
@Test
  public void shouldOverrideMigrationsDirFromConfig() {
    // Given:
    when(config.getString(MigrationConfig.KSQL_MIGRATIONS_DIR_OVERRIDE)).thenReturn(CUSTOM_DIR);

    // When / Then:
    assertThat(MigrationsDirectoryUtil.getMigrationsDir(migrationsConfigPath, config), is(CUSTOM_DIR));
  }