Addressed comments

src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java

@@ -1294,6 +1294,12 @@ public class KinesisClientLibConfiguration {
         return this;
     }
 
+    public KinesisClientLibConfiguration withMaxRecordsCount(final int maxRecordsCount) {
+        checkIsValuePositive("maxRecordsCount", maxRecordsCount);
+        recordsFetcherFactory.setMaxRecordsCount(maxRecordsCount);
+        return this;
+    }
+
     /**
      * @param timeoutInSeconds The timeout in seconds to wait for the MultiLangProtocol to wait for
      */

src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/RecordsFetcherFactory.java

@@ -32,6 +32,8 @@ public interface RecordsFetcherFactory {
 
     void setMaxByteSize(int maxByteSize);
 
+    void setMaxRecordsCount(int maxRecordsCount);
+
     void setDataFetchingStrategy(DataFetchingStrategy dataFetchingStrategy);
 
 }

src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java

@@ -14,7 +14,6 @@
  */
 package com.amazonaws.services.kinesis.clientlibrary.lib.worker;
 
-import lombok.Setter;
 import lombok.extern.apachecommons.CommonsLog;
 
 import java.util.concurrent.Executors;
@@ -48,14 +47,22 @@ public class SimpleRecordsFetcherFactory implements RecordsFetcherFactory {
         }
     }
 
+    @Override
     public void setMaxSize(int maxSize){
         this.maxSize = maxSize;
     }
 
+    @Override
     public void setMaxByteSize(int maxByteSize){
         this.maxByteSize = maxByteSize;
     }
 
+    @Override
+    public void setMaxRecordsCount(int maxRecordsCount) {
+        this.maxRecordsCount = maxRecordsCount;
+    }
+
+    @Override
     public void setDataFetchingStrategy(DataFetchingStrategy dataFetchingStrategy){
         this.dataFetchingStrategy = dataFetchingStrategy;
     }