container/src/main/java/com/streamsets/datacollector/lineage/LineagePublisherTaskImpl.java
private LineagePublisherDefinition getDefinition(String name) {
    String defConfig = LineagePublisherConstants.configDef(name);
    String publisherDefinition = configuration.get(defConfig, null);
    if(StringUtils.isEmpty(publisherDefinition)) {
      throw new IllegalArgumentException(Utils.format("Missing definition '{}'", defConfig));
    }

    String []lineagePluginDefs = publisherDefinition.split("::");
    if(lineagePluginDefs.length != 2) {
      throw new IllegalStateException(Utils.format(
        "Invalid definition '{}', expected $libraryName::$publisherName",
        publisherDefinition
      ));
    }

    LineagePublisherDefinition def = stageLibraryTask.getLineagePublisherDefinition(
      lineagePluginDefs[0], // Library
      lineagePluginDefs[1]  // Plugin name
    );
    if(def == null) {
      throw new IllegalStateException(Utils.format("Can't find publisher '{}'", publisherDefinition));
    }

    return def;
  }
private LineagePublisherDefinition getDefinition(String name) {
    String defConfig = LineagePublisherConstants.configDef(name);
    String publisherDefinition = configuration.get(defConfig, null);
    if(StringUtils.isEmpty(publisherDefinition)) {
      throw new IllegalArgumentException(Utils.format("Missing definition '{}'", defConfig));
    }

    String []lineagePluginDefs = publisherDefinition.split("::");
    if(lineagePluginDefs.length != 2) {
      throw new IllegalStateException(Utils.format(
        "Invalid definition '{}', expected $libraryName::$publisherName",
        publisherDefinition
      ));
    }

    LineagePublisherDefinition def = stageLibraryTask.getLineagePublisherDefinition(
      lineagePluginDefs[0], // Library
      lineagePluginDefs[1]  // Plugin name
    );
    if(def == null) {
      throw new IllegalStateException(Utils.format("Can't find publisher '{}'", publisherDefinition));
    }

    return def;
  }
Parse given configuration declaration of lineage plugin and return appropriate definition.

This method will throw exceptions on all error paths.