Details
-
Bug
-
Status: Open
-
P1
-
Resolution: Unresolved
-
2.9.0
-
None
-
None
Description
While using KafkaIO as bounded source (with withMaxReadTime() or withMaxNumRecords()) it seems doesn't commit offsets all the time.
See the details in the discussion on user@list.
Attachments
Issue Links
- relates to
-
BEAM-2185 KafkaIO bounded source
- Open