[ https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexey Romanenko resolved BEAM-9627. ------------------------------------ Fix Version/s: Not applicable Resolution: Not A Problem I close this issue since required functionality can be implemented on user side by creating custom consumer client. > 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 > Fix For: Not applicable > > > 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)