Daniel Mills created BEAM-9627:
----------------------------------
Summary: 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
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)
