如何禁用客户端脚本的Kafka主机名验证？

问题描述

您知道如何使用kafka-console-consumer.sh之类的Kafka脚本来禁用Kafka主机名验证吗？

这是我现在的配置：

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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafka hostname verification