[
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.
was:
We can provide a special pipeline that simply writes synthetic data to a PubSub
topic. Then this data can be read from a subscription in a streaming test (eg.
in python SDK tests or others).
> 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.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
