[BEAM-13171] Support for stopReadTime on KafkaIO SDF

• Type: Improvement
• Status: Triage Needed
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.36.0
• Component/s: io-java-kafka
• Assignee: Mostafa Aghajani
• Reporter: Mostafa Aghajani
• Created: 03/Nov/21 08:08
• Updated: 13/Apr/23 11:08
• Resolved: 09/Dec/21 20:48

Description

There is already the support for startReadTime using SDF when the Kafka version is supported.

I want to add the support for stopReadTIme so we can extract messages from Kafka only up to a point in time and then the task will be finished.

One use case: when you want to only re-process (re-read) a period of time for a Kafka topic in your pipeline.

Issue Links

• links to: GitHub Pull Request #15951
• links to: GitHub Pull Request #16194