diff --git a/bundles/com.amazonaws.eclipse.sdk.ui/samples/AmazonKinesis/AmazonKinesisApplicationSample.java b/bundles/com.amazonaws.eclipse.sdk.ui/samples/AmazonKinesis/AmazonKinesisApplicationSample.java index 8aa15085..0cc4170c 100644 --- a/bundles/com.amazonaws.eclipse.sdk.ui/samples/AmazonKinesis/AmazonKinesisApplicationSample.java +++ b/bundles/com.amazonaws.eclipse.sdk.ui/samples/AmazonKinesis/AmazonKinesisApplicationSample.java @@ -92,7 +92,7 @@ public static void main(String[] args) throws Exception { credentialsProvider, workerId); kinesisClientLibConfiguration.withInitialPositionInStream(SAMPLE_APPLICATION_INITIAL_POSITION_IN_STREAM); - + kinesisClientLibConfiguration.withCallProcessRecordsEvenForEmptyRecordList(true); IRecordProcessorFactory recordProcessorFactory = new AmazonKinesisApplicationRecordProcessorFactory(); Worker worker = new Worker(recordProcessorFactory, kinesisClientLibConfiguration);