Re: How to configure external service for Kafka IO to run the flink job in k8s

2022-07-21 Thread Chamikara Jayalath via user
Command for starting a customer expansion service is available here: https://beam.apache.org/documentation/sdks/python-multi-language-pipelines/#choose-an-expansion-service Also you can customize the environment set by this expansion service in the expanded transforms using the environementType an

Re: How to configure external service for Kafka IO to run the flink job in k8s

2022-07-18 Thread Ahmet Altay via user
Adding a few relevant folks who could help answer this question: @John Casey @Chamikara Jayalath @Robert Bradshaw Lydian, if you have any other information please share an update. Ahmet On Tue, Jun 7, 2022 at 12:49 AM Lydian wrote: > Hi Folks, > > I am trying to set up the Beam environment