You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Michael Wizner (Jira)" <ji...@apache.org> on 2020/10/21 15:08:00 UTC

[jira] [Commented] (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=17218336#comment-17218336 ] 

Michael Wizner commented on BEAM-9627:
--------------------------------------

Hi [~aromanenko], is this solution applicable to the Python API? I've been wondering how to do this in Python since Python API doesn't expose those factory functions.
Is this currently possible to do via Python API or should I raise a new issue about it in the io-py-kafka component?

> 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: P3
>             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)