"我在使用 strom 集成 kafka 时,由于 kafka 方设置了 sasl 鉴权,所以在 strom 端进行相应配置后,在本地调试通过部署到线上使用生产集群运行时,后台一直报“Could not find a ‘KafkaClient’ entry in the JAAS configuration. Syste .."

Strom 使用 SASL 鉴权时,通过 System.setProperty 设定的值在别的地方获取不到

本贴最后更新于 185 天前,其中的信息可能已经事过景迁

我在使用 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 时有什么特别需要注意的地方吗?

  • Kafka

    Kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是现代系统中许多功能的基础。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。

    22 引用 • 34 回帖 • 170 关注
  • Storm
    4 引用 • 8 回帖 • 1 关注
  • SASL
    1 引用 • 7 回帖
  • Q&A

    提问之前请先看一下这篇文章 《提问的智慧》精读注解版,好的问题比好的答案更有价值。

    940 引用 • 5902 回帖 • 607 关注
感谢    关注    收藏    赞同    反对    举报    分享
7 回帖    
请输入回帖内容...
  • 88250      

    是不是需要重启?

    1 回复
       感谢    赞同    反对    举报    折叠    分享    评论    回复
  • 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= 也不行

       感谢    赞同    反对    举报    折叠    分享    评论    回复
  • 88250      

    kafka-client 的版本用最新的?

    1 回复
       感谢    赞同    反对    举报    折叠    分享    评论    回复
  • KWeier            

    用的是0.10.0.0版本的,主要是本地模式可以,生产模式不行这一点让我很烦恼。

       感谢    赞同    反对    举报    折叠    分享    评论    回复
  • 88250      

    没玩过,爱莫能助 😂

    1 回复
       感谢    赞同    反对    举报    折叠    分享    评论    回复
  • KWeier            

    哈哈哈,不过还是谢谢啦

       感谢    赞同    反对    举报    折叠    分享    评论    回复
  • KWeier      

    好吧,果然是因为 kafka-clients 的版本问题造成的!通过对比发现高版本和低版本之间的鉴权逻辑发现完全不一样了,于是就调了调版本号..... 哎,先干活,后续详细补充下。

       感谢    赞同    反对    举报    折叠    分享    评论    回复
请输入回帖内容...