Kafka开启SSL后消费者启动失败

林开心 发表于: 2021-07-30   最后更新时间: 2021-07-30 20:44:59   2,946 游览

Kafka开启SSL后消费者启动失败

1:使用openssl s_client -debug -connect localhost:9093 -tls1验证成功;可以打印出对应信息。

2:修改客户端配置文件:

ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1
security.protocol=SSL
ssl.truststore.type=JKS
ssl.truststore.location=/usr/ca/trust/server.truststore.jks
ssl.truststore.password=test1234
ssl.keystore.type=JKS
ssl.keystore.location=/usr/ca/server/server.keystore.jks
ssl.keystore.password=test1234
ssl.key.password=test1234

3:kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic test --consumer.config /home/kafka_2.11-1.0.0/config/consumer.properties

执行上述消费者命令,报一下信息:

[2021-07-30 17:39:38,863] ERROR [Consumer clientId=consumer-1, groupId=console-consumer-99435] Connection to node -1 failed authentication due to: SSL handshake failed (org.apache.kafka.clients.NetworkClient)
[2021-07-30 17:39:38,865] ERROR Authentication failed: terminating consumer process (kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed
Caused by: javax.net.ssl.SSLHandshakeException: General SSLEngine problem

Caused by: javax.net.ssl.SSLHandshakeException: General SSLEngine problem

Caused by: sun.security.validator.ValidatorException: PKIX path validation failed: java.security.cert.CertPathValidatorException: signature check failed

Caused by: java.security.cert.CertPathValidatorException: signature check failed

Caused by: java.security.SignatureException: Signature does not match.
发表于 2021-07-30

你可以参考下这篇文章,和附近的几篇文章来解决你的问题:
kafka实战SSL

林开心 -> 半兽人 3年前

我按照文档内描述操作,当我增加这个配置后,生产者和消费者就无法正常使用了,并提示 SSL handshake failed 。

ssl.client.auth=required
半兽人 -> 林开心 3年前

实战指南看了吗?文章的下面。

林开心 -> 半兽人 3年前

我按照指南正确配置了,可以生产消费,配置如下

security.protocol=SSL
ssl.keystore.location=/usr/ca/server/server.keystore.jks
ssl.keystore.password=test1234
ssl.key.password=test1234
ssl.truststore.location=/usr/ca/trust/server.truststore.jks
ssl.truststore.password=test1234

我有两个问题:
1:生成的client.truststore.jks和client.keystore.jks一直没有用到,这个是需要配合SASL/SCRAM使用的吗?
2:每次消费者关闭后,都会提示以下WARN信息,这个有影响吗?

WARN Failed to send SSL Close message  (org.apache.kafka.common.network.SslTransportLayer)
半兽人 -> 林开心 3年前

1、它的作用参考:https://www.orchome.com/171#item-3
2、这个没关系,正常的关闭打印。

k. -> 林开心 2年前

你的配置就是删除required?

林开心 -> k. 2年前

是的

你的答案

查看kafka相关的其他问题或提一个您自己的问题