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

Update ShardEnd checkpoint failure messaging (#591)

Browse source 
* Update shard end checkpoint failure messaging

* Update shard end checkpoint failure messaging
This commit is contained in:
Micah Jaffe 2019-08-13 13:18:52 -07:00 committed by Sahil Palvia
parent 161590c2ce
commit c2a3f18670
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java
View file

@ -106,8 +106,9 @@ public class ShutdownTask implements ConsumerTask {
ExtendedSequenceNumber lastCheckpointValue = recordProcessorCheckpointer.lastCheckpointValue(); ExtendedSequenceNumber lastCheckpointValue = recordProcessorCheckpointer.lastCheckpointValue();
if (lastCheckpointValue == null if (lastCheckpointValue == null
|| !lastCheckpointValue.equals(ExtendedSequenceNumber.SHARD_END)) { || !lastCheckpointValue.equals(ExtendedSequenceNumber.SHARD_END)) {
throw new IllegalArgumentException( throw new IllegalArgumentException("Application didn't checkpoint at end of shard "
"Application didn't checkpoint at end of shard " + shardInfo.shardId()); + shardInfo.shardId() + ". Application must checkpoint upon shard end. " +
"See ShardRecordProcessor.shardEnded javadocs for more information.");
} }
} else { } else {
shardRecordProcessor.leaseLost(LeaseLostInput.builder().build()); shardRecordProcessor.leaseLost(LeaseLostInput.builder().build());