public static PartitionScheme getEnum()

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

• 15 lines of code
• 6 McCabe index (conditional complexity)

    public static PartitionScheme getEnum(String value) {
      if (value.equals("round_robin")) {
        return PartitionScheme.ROUND_ROBIN;
      } else if (value.equals("hash_key")) {
        return PartitionScheme.HASH_KEY;
      } else if (value.equals("hash_value")) {
        return PartitionScheme.HASH_VALUE;
      } else if (value.equals("kafka_partitioner")) {
        return PartitionScheme.KAFKA_PARTITIONER;
      } else if (value.equals("ordering_key")) {
        return PartitionScheme.ORDERING_KEY;
      } else {
        return null;
      }
    }