lostluck opened a new issue, #22302: URL: https://github.com/apache/beam/issues/22302
### What happened? The Java KafkaIO SDF implementation is experiencing issues #21730 and the Xlang wrappers need to be updated to pass an experiment flag to the Java Expansion service. This issue tracks doing the same to the Go KafkaIO wrapper, to pass the additional args to the automatically started up expansion service, as it was done to the python wrapper in #22286. https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go#L90 Additional args can probably be added as a new "ExpansionServiceOption" https://github.com/apache/beam/blob/896bf1af7782856cad6fcbfe4c93867252ee3548/sdks/go/pkg/beam/core/runtime/xlangx/registry.go#L289 And plumbed through to https://github.com/apache/beam/blob/d2fe48e8c142a3ffc16957b779f5e7bcc8a034ab/sdks/go/pkg/beam/core/runtime/xlangx/expand.go#L180 for the started service. ### Issue Priority Priority: 2 ### Issue Component Component: sdk-go -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
