From d31758727c3d3a1c56271b1790ca62ca6093f62c Mon Sep 17 00:00:00 2001 From: Joshua Kim Date: Tue, 14 Apr 2020 04:37:11 -0400 Subject: [PATCH] Fixing bug --- .../kinesis/checkpoint/ShardRecordProcessorCheckpointer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardRecordProcessorCheckpointer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardRecordProcessorCheckpointer.java index 4e831c4b..8ecf58ec 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardRecordProcessorCheckpointer.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardRecordProcessorCheckpointer.java @@ -186,7 +186,7 @@ public class ShardRecordProcessorCheckpointer implements RecordProcessorCheckpoi @Override public PreparedCheckpointer prepareCheckpoint(String sequenceNumber, byte[] applicationState) throws KinesisClientLibDependencyException, InvalidStateException, ThrottlingException, ShutdownException, IllegalArgumentException { - return prepareCheckpoint(sequenceNumber, 0, null); + return prepareCheckpoint(sequenceNumber, 0, applicationState); } /**