Functions deadletter topic is not the same as enableRetry (apache#7610)

Co-authored-by: Sanjeev Kulkarni <[email protected]>
mfleming · Jul 24, 2020 · 835f506 · 835f506
1 parent d75cbb4
commit 835f506
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java
@@ -105,7 +105,7 @@ public void open(Map<String, Object> config, SourceContext sourceContext) throws
                 if (pulsarSourceConfig.getDeadLetterTopic() != null && !pulsarSourceConfig.getDeadLetterTopic().isEmpty()) {
                     deadLetterPolicyBuilder.deadLetterTopic(pulsarSourceConfig.getDeadLetterTopic());
                 }
-                cb = cb.enableRetry(true).deadLetterPolicy(deadLetterPolicyBuilder.build());
+                cb = cb.deadLetterPolicy(deadLetterPolicyBuilder.build());
             }
 
             Consumer<T> consumer = cb.subscribeAsync().join();