From 81754f3a00fb72e3ee7e1edec269952f0d25a34a Mon Sep 17 00:00:00 2001 From: Musti Date: Thu, 23 Sep 2021 22:40:59 -0500 Subject: [PATCH] Adding New Security Feature --- .../samples/AmazonKinesis/AmazonKinesisApplicationSample.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);