apache-kafka - 为 Kafka 客户端启用 SSL

Question

Kafka 允许客户端通过 SSL 进行连接。默认情况下禁用 SSL，但我已通过引用以下链接启用。
http://docs.confluent.io/2.0.0/kafka/ssl.html

所有配置完成后，Producer/Consumer 无法生产/消费消息。

    [2016-02-29 09:20:49,189] ERROR Error when sending message to topic ssltopic with key: null, value: 2 bytes with error: Failed to update metadata after 60000 ms. (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
sas
[2016-02-29 09:21:16,031] WARN Failed to send SSL Close message  (org.apache.kafka.common.network.SslTransportLayer)
java.io.IOException: Connection reset by peer

Answer 1

supermonk 的上述答案澄清了大多数要检查的地方。我遇到了与 OP 类似的问题，错误不在代理配置中，而是在客户端配置中。
在官方documentation ，虽然他们隐含地提到创建 client.keystore 作为第 1 步，但我没有像为 server.keystore 所做的那样使用 CA 签署证书。这导致 Kafka 代理拒绝来自客户端(生产者/消费者)的连接。
执行这两个步骤已经消除了我的问题。

keytool -keystore kafka.client.keystore.jks -alias localhost -certreq -file cert-file
openssl x509 -req -CA ca-cert -CAkey ca-key -in cert-file -out cert-signed -days $VALIDITY -CAcreateserial -passin pass:$PASSWORD

keytool -keystore kafka.client.keystore.jks -alias CARoot -import -file ca-cert
keytool -keystore kafka.client.keystore.jks -alias localhost -import -file cert-signed

这将使用 CA 证书签署证书并将 CARoot 以及签署的证书添加到 client.keystore。

引用: Confluent blog on securing Apache Kafka