Add minimum idleTimeBetweenReadsInMillis to multilang

amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/coordinator/KinesisClientLibConfiguration.java

@@ -70,6 +70,12 @@ public class KinesisClientLibConfiguration {
      */
     public static final long DEFAULT_IDLETIME_BETWEEN_READS_MILLIS = 1000L;
 
+    /**
+     * The minimum time {@link ShardConsumer} should sleep between calls to
+     * {@link com.amazonaws.services.kinesis.AmazonKinesis#getRecords(com.amazonaws.services.kinesis.model.GetRecordsRequest)}.
+     */
+    public static final long MIN_IDLE_MILLIS_BETWEEN_READS = 200L;
+
     /**
      * Don't call processRecords() on the record processor for empty record lists.
      */
@@ -1098,6 +1104,10 @@ public KinesisClientLibConfiguration withMaxRecords(int maxRecords) {
      */
     public KinesisClientLibConfiguration withIdleTimeBetweenReadsInMillis(long idleTimeBetweenReadsInMillis) {
         checkIsValuePositive("IdleTimeBetweenReadsInMillis", idleTimeBetweenReadsInMillis);
+        if (idleTimeBetweenReadsInMillis < MIN_IDLE_MILLIS_BETWEEN_READS) {
+            throw new IllegalArgumentException("idleTimeBetweenReadsInMillis must be greater than or equal to "
+                    + MIN_IDLE_MILLIS_BETWEEN_READS + " but current value is " + idleTimeBetweenReadsInMillis);
+        }
         this.idleTimeBetweenReadsInMillis = idleTimeBetweenReadsInMillis;
         return this;
     }

amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PollingConfig.java

@@ -44,6 +44,8 @@ public class PollingConfig implements RetrievalSpecificConfig {
 
     public static final int DEFAULT_MAX_RECORDS = 10000;
 
+    public static final long MIN_IDLE_MILLIS_BETWEEN_READS = 200L;
+
     /**
      * Configurable functional interface to override the existing DataFetcher.
      */
@@ -138,9 +140,14 @@ public void setIdleTimeBetweenReadsInMillis(long idleTimeBetweenReadsInMillis) {
     /**
      * Set the value for how long the ShardConsumer should sleep in between calls to
      * {@link KinesisAsyncClient#getRecords(GetRecordsRequest)}. If this is not specified here the value provided in
-     * {@link RecordsFetcherFactory} will be used.
+     * {@link RecordsFetcherFactory} will be used. Cannot set value below MIN_IDLE_MILLIS_BETWEEN_READS
      */
     public PollingConfig idleTimeBetweenReadsInMillis(long idleTimeBetweenReadsInMillis) {
+        if (idleTimeBetweenReadsInMillis < MIN_IDLE_MILLIS_BETWEEN_READS) {
+            throw new IllegalArgumentException("Value for idleTimeBetweenReadsInMillis must be less than or equal to "
+                    + MIN_IDLE_MILLIS_BETWEEN_READS + " but current value is "
+                    + idleTimeBetweenReadsInMillis());
+        }
         usePollingConfigIdleTimeValue = true;
         this.idleTimeBetweenReadsInMillis = idleTimeBetweenReadsInMillis;
         return this;

amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PollingConfigTest.java

@@ -48,4 +48,9 @@ public void testInvalidStateMultiWithStreamName() {
     public void testInvalidRecordLimit() {
         config.maxRecords(PollingConfig.DEFAULT_MAX_RECORDS + 1);
     }
+
+    @Test(expected = IllegalArgumentException.class)
+    public void testInvalidIdleMillisLimit() {
+        config.idleTimeBetweenReadsInMillis(PollingConfig.MIN_IDLE_MILLIS_BETWEEN_READS - 1);
+    }
 }