Hi everyone, I'm trying to understand how to use cross-language transforms, more specifically, how to use xlang/kafkaio in the Go SDK.
I know I have to specify the address of an expansion service, and that this service won't be automatically started (BEAM-12862). My question is: how do I get/start this service? If I run my pipeline using the dataflow runner, do I have to expose this service to the pipeline? Or is it only used during pipeline construction time? Best regards, André
