awslabs/amazon-kinesis-client v1.8.6

Release 1.8.6 of the Amazon Kinesis Client Library for Java

on GitHub

Release 1.8.6

• Add prefetching of records from Kinesis
  Prefetching 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.
  Pre-fetching supports the following configuration values:

  Name	Default	Description
  dataFetchingStrategy	DEFAULT	Which data fetching strategy to use
  maxPendingProcessRecordsInput	3	The maximum number of process records input that can be queued
  maxCacheByteSize	8 MiB	The maximum number of bytes that can be queued
  maxRecordsCount	30,000	The maximum number of records that can be queued
  idleMillisBetweenCalls	1,500 ms	The amount of time to wait between calls to Kinesis

  • PR #246