我在使用 strom 集成 kafka 时,由于 kafka 方设置了 sasl 鉴权,所以在 strom 端进行相应配置后,在本地调试通过部署到线上使用生产集群运行时,后台一直报“Could not find a 'KafkaClient' entry in the JAAS configuration. System property ”的错误。
通过排查发现 kafka 源码发现在使用 String jaasConfigFile = System.getProperty(JaasUtils.JAVA\_LOGIN\_CONFIG\_PARAM);
时返回结果为 null,请问下 strom 使用 System.setProperty 时有什么特别需要注意的地方吗?
Strom 使用 SASL 鉴权时,通过 System.setProperty 设定的值在别的地方获取不到
相关帖子
- 其他回帖
-
-
KWeier •作者
应该不是,我已经重启过了。还看了下 storm.py 里的配置,里面有部分是
jvmopts=JAR_JVM_OPTS + ["-Dstorm.jar=" + tmpjar] +
["-Dstorm.dependency.jars=" + ",".join(local_jars)] +
["-Dstorm.dependency.artifacts=" + json.dumps(artifact_to_file_jars)])
添加上-Djava.security.auth.login.config=也不行 -
KWeier •作者
好吧,果然是因为 kafka-clients 的版本问题造成的!通过对比发现高版本和低版本之间的鉴权逻辑发现完全不一样了,于是就调了调版本号.....
哎,先干活,后续详细补充下。 - 查看全部回帖
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于