Lukasz Gajowy created BEAM-6207:
-----------------------------------
Summary: 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
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).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
