Replace FlowTimestampPolicy by shipped CustomTimestampPolicyWithLimitedDelay
Description
Acceptance / Success Criteria
None
Lucidchart Diagrams
Activity
Show:
Stefan Wachter May 19, 2021 at 8:15 PM
Fixed
Details
Details
Assignee
Stefan Wachter
Stefan WachterReporter
Stefan Wachter
Stefan WachterLabels
Sprint
None
Fix versions
Priority
MinorPagerDuty
PagerDuty Incident
PagerDuty
PagerDuty Incident
Created May 19, 2021 at 4:59 PM
Updated July 6, 2021 at 2:38 PM
Resolved May 27, 2021 at 12:58 PM
The CustomTimestampPolicyWithLimitedDelay that is shipped with Apache Beam is more robust in case of timestamps that are lying in the future and to Kafka idleness than our own implementation.