From 7a09b77b4618dd28f2f65b5b81c22e9a94dbe7e1 Mon Sep 17 00:00:00 2001 From: jushkem <20001595+jushkem@users.noreply.github.com> Date: Mon, 27 Jan 2020 12:55:01 -0800 Subject: [PATCH] Tuning default request response timeout to 60 seconds. --- .../java/software/amazon/kinesis/lifecycle/ShardConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java index 5545fc03..99a680bf 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java @@ -52,7 +52,7 @@ import software.amazon.kinesis.retrieval.RecordsPublisher; @KinesisClientInternalApi public class ShardConsumer { - public static final int MAX_TIME_BETWEEN_REQUEST_RESPONSE = 35000; + public static final int MAX_TIME_BETWEEN_REQUEST_RESPONSE = 60 * 1000; private final RecordsPublisher recordsPublisher; private final ExecutorService executorService; private final ShardInfo shardInfo;