in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ConverterUtils.java [34:42]
static DeadLetterPolicy toDeadLetterPolicy(DeadLetterPolicyConf deadLetterPolicy) {
if (deadLetterPolicy == null) {
return null;
}
return DeadLetterPolicy.builder().maxRedeliverCount(deadLetterPolicy.getMaxRedeliverCount())
.deadLetterTopic(deadLetterPolicy.getDeadLetterTopic())
.retryLetterTopic(deadLetterPolicy.getRetryLetterTopic())
.initialSubscriptionName(deadLetterPolicy.getInitialSubscriptionName()).build();
}