[
https://issues.apache.org/jira/browse/BEAM-6207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukasz Gajowy updated BEAM-6207:
--------------------------------
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.
was:
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.
> extend "Data insertion Pipeline" with Kafka IO
> ----------------------------------------------
>
> Key: BEAM-6207
> URL: https://issues.apache.org/jira/browse/BEAM-6207
> Project: Beam
> Issue Type: Sub-task
> Components: testing
> Reporter: Lukasz Gajowy
> Assignee: Lukasz Gajowy
> Priority: Trivial
>
> 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.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
