Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
There was a data loss bug in Dataflow when executing x-lang pipeline, which prevents us using ReadFromKafkaDoFn for KafkaIO default. Now the bug is fixed on dataflow side and we should use ReadFromKafkaDoFn when with beam_fn_api instead of using sdf wrapper.
Attachments
Issue Links
- links to