У меня есть кластер kafka из 3 брокеров kafka на 3 разных серверах.
Предположим, что три сервера.
99.99.99.1
99.99.99.2
99.99.99.3
Все 3 сервера имеют общий путь, на котором находится kafka.
Я создал 3 server.properties с именем
server1.properties
server2.properties
server3.properties
server1.properties выглядит следующим образом:
broker.id=1
port=9094
listeners=SSL://99.99.99.1:9094
offsets.topic.replication.factor=3
transaction.state.log.replication.factor=3
transaction.state.log.min.isr=3
zookeeper.connect=99.99.99.1:2181,99.99.99.2:2182,99.99.99.3:2183
ssl.keystore.location=xyz.jks
ssl.keystore.password=password
ssl.key.password=password
ssl.truststore.location=xyz.jks
ssl.truststore.password=password
ssl.client.auth=required
security.inter.broker.protocol=SSL
Аналогичным образом выглядят два других свойства сервера.
Вопросы / Запрос:
Мне нужно, чтобы потребитель и производитель должны были соединяться с использованием SSL, и даже все брокеры должны соединяться друг с другом с помощью SSL. Подходит ли моя конфигурация для этого?
Я продолжаю получать ошибку ниже, это обычно?
WARN Не удалось отправить SSL Закрыть сообщение
(Org.apache.kafka.common.network.SslTransportLayer)
java.io.IOException: сломанная труба