Skip to content

Commit 8e09a2a

Browse files
authored
Increasing ack timeout to 4 hours for kds source (opensearch-project#6547)
Signed-off-by: Divyansh Bokadia <dbokadia@amazon.com>
1 parent 58e755b commit 8e09a2a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • data-prepper-plugins/kinesis-source/src/main/java/org/opensearch/dataprepper/plugins/kinesis/source/processor

data-prepper-plugins/kinesis-source/src/main/java/org/opensearch/dataprepper/plugins/kinesis/source/processor/KinesisRecordProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public class KinesisRecordProcessor implements ShardRecordProcessor {
5555
private static final Logger LOG = LoggerFactory.getLogger(KinesisRecordProcessor.class);
5656

5757
private static final int DEFAULT_MONITOR_WAIT_TIME_MS = 15_000;
58-
private static final Duration ACKNOWLEDGEMENT_SET_TIMEOUT = Duration.ofSeconds(20);
58+
private static final Duration ACKNOWLEDGEMENT_SET_TIMEOUT = Duration.ofHours(4);
5959

6060
private final StreamIdentifier streamIdentifier;
6161
private final KinesisStreamConfig kinesisStreamConfig;

0 commit comments

Comments
 (0)