in pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/consumer/PulsarKafkaSimpleConsumer.java [341:350]
private SubscriptionType getSubscriptionType(Properties properties) {
String subType = properties != null && properties.contains(SUBSCRIPTION_TYPE)
? properties.getProperty(SUBSCRIPTION_TYPE)
: SubscriptionType.Failover.toString();
try {
return SubscriptionType.valueOf(subType);
} catch (IllegalArgumentException ie) {
return SubscriptionType.Failover;
}
}