您知道如何禁用kafka主机名验证以使用kafka脚本,例如 kafka-console-consumer.sh
?
这是我现在的配置:
security.protocol=SASL_SSL
ssl.endpoint.identification.algorithm=
sasl.mechanism=JWT
我已经定好了 ssl.endpoint.identification.algorithm
如上图所示,我仍然得到以下错误:
Caused by: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
at sun.security.provider.certpath.SunCertPathBuilder.build(SunCertPathBuilder.java:141)
at sun.security.provider.certpath.SunCertPathBuilder.engineBuild(SunCertPathBuilder.java:126)
at java.security.cert.CertPathBuilder.build(CertPathBuilder.java:280)
at sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:445)
我将脚本称为:
$KAFKAHOME/bin/kafka-console-consumer.sh \
--consumer.config myconfig.config \
--bootstrap-server myaddress:myport\
--topic mytopic
暂无答案!
目前还没有任何答案,快来回答吧!