luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

MAX_TIME_BETWEEN_REQUEST_RESPONSE can be changed by the user

Browse source 
fixes #1051
This commit is contained in:
Sam Halliday 2023-02-23 14:07:48 +00:00
parent 70cfc7d7ce
commit 831bc572ea
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java
View file

@ -52,7 +52,7 @@ import software.amazon.kinesis.retrieval.RecordsPublisher;
@KinesisClientInternalApi @KinesisClientInternalApi
public class ShardConsumer { public class ShardConsumer {
public static final int MAX_TIME_BETWEEN_REQUEST_RESPONSE = 60 * 1000; public static final int MAX_TIME_BETWEEN_REQUEST_RESPONSE = Integer.parseInt(System.getProperty("software.amazon.kinesis.lifecycle.ShardConsumer.max_time", "60000"));
private final RecordsPublisher recordsPublisher; private final RecordsPublisher recordsPublisher;
private final ExecutorService executorService; private final ExecutorService executorService;
private final ShardInfo shardInfo; private final ShardInfo shardInfo;