[
https://issues.apache.org/jira/browse/BEAM-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073702#comment-17073702
]
Alexey Romanenko edited comment on BEAM-9627 at 4/2/20, 12:55 PM:
------------------------------------------------------------------
I close this issue since required functionality can be implemented on user side
by creating custom consumer client.
We may reopen this issue in case if such client will be contributed back to
Beam.
was (Author: aromanenko):
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)
