Kafka jaas在Flink集群上验证失败-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

Kafka jaas在Flink集群上验证失败

flink小助手 2018-11-28 16:06:01 2581

"我遇到了一个非常奇怪的问题

Could not find a ""KafkaClient"" entry in the JAAS configuration. System property ""java.security.auth.login.config"" is /etc/kafka/kafka_sink_jaas.conf
当我使用Apache Beam KafkaIO从kafka消耗记录时,在单个节点上的Apache Flink集群。JAAS文件包含“KafkaClient”,但Flink群集找不到该条目。有谁知道造成的原因?"

消息中间件 Kafka Apache 流计算
分享到
取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:16:49

    "
    我已经解决了这个问题。它是由flink cluster kerberos配置引起的。只需要在flink-conf.yaml上设置一些配置即可使其工作正常!

    设置如下:

    security.kerberos.login.use-ticket-cache: false
    security.kerberos.login.keytab: /etc/kafka/kafka.keytab
    security.kerberos.login.principal: kafka@HADOOP.COM
    security.kerberos.login.contexts: Client,KafkaClient"

    0 0
微服务
使用钉钉扫一扫加入圈子
+ 订阅

构建可靠、高效、易扩展的技术基石

推荐文章
相似问题