Details
-
Improvement
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
Description
Have KafkaIO’s WriteRecord PTransform output a PCollection, an extensible WriteResult type similar to that of BigQuery’s WriteResult output.
The original input, of <ProducerRecord> type, will be returned as part of the WriteResult (or similar type), with a getter function.
Attachments
Issue Links
- is related to
-
BEAM-13298 Add "withResults()" for KafkaIO.write
- Open