[GitHub] [beam] lostluck opened a new issue, #22302: [Bug]: Update Go KafkaIO wrapper to work around #21730 (Pass additional args to automated expansion service startup)

[GitBox <gi...@apache.org>]

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: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org