[ https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexey Romanenko updated BEAM-9627: ----------------------------------- Status: Open (was: Triage Needed) > KafkaIO needs better support for SSL > ------------------------------------ > > Key: BEAM-9627 > URL: https://issues.apache.org/jira/browse/BEAM-9627 > Project: Beam > Issue Type: Improvement > Components: io-java-kafka > Reporter: Daniel Mills > Priority: Minor > > Configuring SSL for kafka requires pointing an option at local files > containing keys and roots of trust as described here: > [https://www.confluent.io/blog/apache-kafka-security-authorization-authentication-encryption/] > Currently, it is somewhat tricky to ensure that these files are written > before KafkaIO starts reading from the source; one potential option would be > to add an init hook where the user could download keys from the keystore of > their choice and write them to local files. -- This message was sent by Atlassian Jira (v8.3.4#803005)