Ajo Thomas created BEAM-7240:
--------------------------------
Summary: Kinesis IO Watermark Improvements
Key: BEAM-7240
URL: https://issues.apache.org/jira/browse/BEAM-7240
Project: Beam
Issue Type: Improvement
Components: io-java-kinesis
Reporter: Ajo Thomas
Currently, watermarks in kinesis IO are computed taking into account the record
arrival time in a {{KinesisRecord}}. The arrival time might not always be the
right representation of the event time. Also, as the per current logic, the end
user of the IO cannot control watermark computation in any way.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
