Проблема: при попытке отправить сообщение от производителя с 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
на стороне брокера.В настоящее время я отключил это свойство, когда сталкиваюсь с проблемой, упомянутой выше.
Пример снимка экрана:
PT(consumer)">