kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java [88:98]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      } else {
        return null;
      }
    }

    /** Validator class for {@link CloudPubSubSinkConnector.OrderingKeySource}. */
    public static class Validator implements ConfigDef.Validator {

      @Override
      public void ensureValid(String name, Object o) {
        String value = (String) o;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java [98:108]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      } else {
        return null;
      }
    }

    /** Validator class for {@link CloudPubSubSourceConnector.PartitionScheme}. */
    public static class Validator implements ConfigDef.Validator {

      @Override
      public void ensureValid(String name, Object o) {
        String value = (String) o;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -