[BEAM-2468] Reading Kinesis records in the background

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: io-java-kinesis
• Assignee: Paweł Kaczmarczyk
• Reporter: Paweł Kaczmarczyk
• Created: 19/Jun/17 12:46
• Updated: 16/May/20 13:44
• Resolved: 31/Jan/18 19:52

Description

Currently Kinesis records are read on demand in a runner's thread. We may instead read the records in a background with separate threads and store time in the buffer which will result in a major performance improvement.

Issue Links

• links to: GitHub Pull Request #3930