Details
-
Sub-task
-
Status: Resolved
-
P4
-
Resolution: Resolved
-
None
-
None
Description
Since now we have the Data insertion pipeline based on PubSubIO, it can be easily extended with KafkaIO if needed. Same data then could be published to any of the sinks leaving out the choice and enabling the data insertion pipeline for Flink.
Attachments
Issue Links
- is a clone of
-
BEAM-6201 Provide a "Data insertion pipeline" for Python suites
- Resolved
- links to