Невозможно создавать сообщения для Kafka с включенным SSL

Question

Я настроил kafka (1.0) с включенным SSL и добавил свойство слушателей как listeners=PLAINTEXT://:9092,SSL://:9093 И рекламируемые слушатели как advertisted.listeners=PLAINTEXT://PUBLICIP:9092,SSL://PUBLICIP:9093

Я могу создавать сообщения с портом 9092, но не могу сделать это с включенным SSL 9093. Ниже приведена ошибка, которую я получаю

[2018-05-03 10:51:41,990] ERROR Error when sending message to topic test with key: null, value: 16 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)

org.apache.kafka.common.errors.TimeoutException: не удалось обновить метаданные после 60000 мс.

Вот команда продюсера, которую я использую

bin/kafka-console-producer.sh --broker-list PUBLICIP1:9093,PUBLICIP2:9093,PUBLICIP3:9093 --topic test --property security.protocol=SSL --producer.config ~/client.properties

Вот записи в client.properties

security.protocol=SSL
ssl.truststore.location=/home/ubuntu/kafka.client.truststore.jks
ssl.truststore.password=trustpassword

Answer 1

Если вы используете версии 2.0+ ниже, это команда для производителя консоли

kafka-console-producer –broker-list kafka.example.com:9093 –topic securing-kafka –producer.config /etc/kafka/producer_ssl.properties

provider_ssl.properties

bootstrap.servers=kafka.example.com:9093
security.protocol=SSL
ssl.truststore.location=/etc/security/tls/kafka.client.truststore.jks
ssl.truststore.password=test1234
ssl.keystore.location=/etc/security/tls/kafka.client.keystore.jks
ssl.keystore.password=test1234
ssl.key.password=test1234