Отправка SSL-сообщений на открытый текст в Кафке - PullRequest
0 голосов
/ 29 января 2019

Проблема: при попытке отправить сообщение от производителя с SSL сообщение получено на стороне клиента в виде открытого текста.Независимо от типа производителя (SSL / Plaintext) все сообщения отправляются потребителю открытого текста.

Что я сделал / делаю: Я пытаюсь развернуть таблицу управления kafka в кластере GKE с включенным шифрованием SSL.Я использую схему управления инкубатором для kafka и zookeeper.Я использовал эту ссылку для справки.Мой configurationOverride выглядит следующим образом:

configurationOverrides:
    "offsets.topic.replication.factor": 1
    "confluent.support.metrics.enable": false
    "listeners": "PLAINTEXT://:9092,SSL://:9901"
    "advertised.listeners": "SSL://${POD_IP}:9901"

    "ssl.keystore.filename": "kafka.broker1.keystore.jks"
    "ssl.keystore.credentials": "broker1_keystore_creds"
    "ssl.key.credentials": "broker1_sslkey_creds"

    "ssl.truststore.filename": "kafka.broker1.truststore.jks"
    "ssl.truststore.credentials": "broker1_truststore_creds"
    "ssl.truststore.type": "JKS"

Я сгенерировал требуемые секреты из вышеуказанных трастовых и хранилищ ключей и установил их в /etc/kafka/secrets/

При настройке "security.inter.broker.protocol": "SSL" Я получаюследующее сообщение об ошибке: unable to find valid certification path to requested target на стороне брокера.В настоящее время я отключил это свойство, когда сталкиваюсь с проблемой, упомянутой выше.

Пример снимка экрана: imagePT(consumer)">

...