> The issue is also tracked here: > https://jira.apache.org/jira/browse/BEAM-7870 There are some suggestions > in the issue. I think the best solution is to allow execution of the > source API parts of KafkaIO/PubSubIO (on the Runner) and the following > UDFs (in the environment). Since those do not cross the language > boundary, it is simply a matter of settings this up correctly. >
Thanks, Max. I added some feedback to the issue.
