Support timeouts, and retry for GetRecords calls.
Applications can now use an Async retry for getRecords calls to Kinesis. In addition to setting the retryGetRecordsInSeconds timeout, the application must also provide a maxGetRecordsThreadPool size for concurrent requests.
Support configuring the graceful shutdown timeout for MultiLang Clients using shutdownGraceMillis. This adds support for setting the timeout that the Java process will wait for the MutliLang client to complete graceful shutdown.
Record pre-fetching
This will retrieve and queue additional records from Kinesis while the application is processing existing records.
Prefetching can be enabled by setting dataFetchingStrategy to PREFETCH_CACHED. Once enabled an additional fetching thread will be started to retrieve records from Kinesis. Retrieved records will be held in a queue until the application is ready to process them.
Logging of long running tasks can be enabled by setting the logWarningForTaskAfterMillis configuration property
Coverage increased (+0.1%) to 88.101% when pulling efd98381d399087892b98687d4d68187e9224b1f on UpdateLibraries into f766e677fc38dc2b043a21973a6efbba7ceba8c3 on master.
Coverage increased (+0.1%) to 88.101% when pulling efd98381d399087892b98687d4d68187e9224b1f on UpdateLibraries into f766e677fc38dc2b043a21973a6efbba7ceba8c3 on master.
KCL: 1.8.1 -> 1.8.8
shutdownGraceMillis
. This adds support for setting the timeout that the Java process will wait for the MutliLang client to complete graceful shutdown.logWarningForTaskAfterMillis
configuration propertyKPL: 0.12.5 -> 0.12.8