You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Alexey Romanenko (Jira)" <ji...@apache.org> on 2020/04/02 12:56:00 UTC
[jira] [Comment Edited] (BEAM-9627) KafkaIO needs better support
for SSL
[ 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)