damccorm opened a new issue, #19664: URL: https://github.com/apache/beam/issues/19664
Sinks like Kafka or Elasticsearch have worked with SSL/TLS. But all of these can read only certificates from a local machine (use java.io.File#File(java.lang.String). In the case of Google Dataflow, we can not easily copy files to a worker, I see two possible variants to read certificates from the worker: 1) somehow copy certificates to a worker from GC Storage 2) in Kafka IO or Elasticsearch IO read certificates directly from GC Storage Any thoughts about how I can solve this issue easily or mb other variants will be helpful. Imported from Jira [BEAM-7519](https://issues.apache.org/jira/browse/BEAM-7519). Original Jira may contain additional context. Reported by: alex3.14. -- 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]
