Increase ack expiry time to 60 seconds

Signed-off-by: Kondaka <[email protected]>
opensearch-project · Nov 28, 2023 · b6244d3 · b6244d3
1 parent b150cce
commit b6244d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...pper-core/src/integrationTest/java/org/opensearch/dataprepper/plugins/InMemorySource.java b/...pper-core/src/integrationTest/java/org/opensearch/dataprepper/plugins/InMemorySource.java
@@ -26,7 +26,7 @@
  */
 @DataPrepperPlugin(name = "in_memory", pluginType = Source.class, pluginConfigurationType = InMemoryConfig.class)
 public class InMemorySource implements Source<Record<Event>> {
-    public static final Duration ACK_EXPIRY_TIME = Duration.ofSeconds(35);
+    public static final Duration ACK_EXPIRY_TIME = Duration.ofSeconds(60);
     private static final Logger LOG = LoggerFactory.getLogger(InMemorySource.class);
 
     private final String testingKey;