Hello.
Another solution might be putting it inside the custom container.
I use it for testing ElasticsearchIO with TLS session.
https://beam.apache.org/documentation/runtime/environments/
https://cloud.google.com/dataflow/docs/guides/using-custom-containers
Below is a dockerfile example
https://
Hi Utkarsh,
you can pass a path in GCS (or a filesystem), and the workers should be
able to download it onto themselves. You'd pass
`gs://my-bucket-name/path/to/trust.jks`. Can you try that?
Best
-P.
On Wed, May 10, 2023 at 1:58 PM Utkarsh Parekh
wrote:
> Hi,
>
> I'm testing a streaming app usin
Hi,
I'm testing a streaming app using kafka, Dafaflow, and Apache beam
[Python].
"Error message from worker: org.apache.beam.sdk.util.UserCodeException:
java.lang.RuntimeException: org.apache.kafka.common.KafkaException: Failed
to construct kafka consumer
org.apache.beam.sdk.util.UserCodeExcepti
