Hi Beam Community, Recently our team added Kafka to Pub/Sub example pipeline to Apache Beam repository. We decided to move E2E tests out of the scope because we needed more time for investigation and implementation. And now the test is ready, the PR is open.
Here are the jira tickets for this PR: https://issues.apache.org/jira/browse/BEAM-11410 https://issues.apache.org/jira/browse/BEAM-11411 Please share your feedback/comments about this proposal in the thread. Here is the PR, please take a look at it and feel free to share your comments: https://github.com/apache/beam/pull/13636 Thank you, Ramazan
