Set source spec's negativeacktimeout as well as timeout (apache#7337)

Co-authored-by: Sanjeev Kulkarni <[email protected]>
vzhikserg · Jun 23, 2020 · a9daf4c · a9daf4c
1 parent 51d2aa4
commit a9daf4c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java b/...-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java
@@ -152,6 +152,8 @@ public static FunctionDetails convert(FunctionConfig functionConfig, ClassLoader
         }
         if (functionConfig.getTimeoutMs() != null) {
             sourceSpecBuilder.setTimeoutMs(functionConfig.getTimeoutMs());
+            // We use negative acks for fast tracking failures
+            sourceSpecBuilder.setNegativeAckRedeliveryDelayMs(functionConfig.getTimeoutMs());
         }
         if (functionConfig.getCleanupSubscription() != null) {
             sourceSpecBuilder.setCleanupSubscription(functionConfig.getCleanupSubscription());