Hi Devs, We are finalizing this PR<https://github.com/apache/beam/pull/13112> with a pipeline that reads from Kafka and writes to Pub/Sub without any transformations in between. We would like to implement e2e tests where we create and execute a pipeline, but we haven't found much information and relevant examples about it.How exactly should we implement such kind of tests? Can we mock somehow Kafka and Pub/Sub or maybe can we set them up using some test environment?
Any information and hints will be greatly appreciated! Thanks, Artur Khanin Akvelon, Inc
