public void ensureValid()

in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java [97:108]

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

      public void ensureValid(String name, Object o) {
        String value = (String) o;
        if (!value.equals(CloudPubSubSinkConnector.OrderingKeySource.NONE.toString())
            && !value.equals(CloudPubSubSinkConnector.OrderingKeySource.KEY.toString())
            && !value.equals(CloudPubSubSinkConnector.OrderingKeySource.PARTITION.toString())) {
          throw new ConfigException(
              "Valid values for "
                  + CloudPubSubSinkConnector.ORDERING_KEY_SOURCE
                  + " are "
                  + Arrays.toString(OrderingKeySource.values()));
        }
      }