public void ensureValid()

in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java [107:121]

15 lines of code
6 McCabe index (conditional complexity)


      public void ensureValid(String name, Object o) {
        String value = (String) o;
        if (!value.equals(CloudPubSubSourceConnector.PartitionScheme.ROUND_ROBIN.toString())
            && !value.equals(CloudPubSubSourceConnector.PartitionScheme.HASH_VALUE.toString())
            && !value.equals(CloudPubSubSourceConnector.PartitionScheme.HASH_KEY.toString())
            && !value.equals(
                CloudPubSubSourceConnector.PartitionScheme.KAFKA_PARTITIONER.toString())
            && !value.equals(CloudPubSubSourceConnector.PartitionScheme.ORDERING_KEY.toString())) {
          throw new ConfigException(
              "Valid values for "
                  + CloudPubSubSourceConnector.KAFKA_PARTITION_SCHEME_CONFIG
                  + " are "
                  + Arrays.toString(PartitionScheme.values()));
        }
      }