请问pyflink如何跟kerberos认证的kafka对接呢？
我把kerberos相关的配置放在某一个flink-conf.yaml里，然后启动了一个local模式*来自志愿者整理的flink
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
1
条回答
写回答
-
我的码呢！？
你好，local模式的pyflink shell是不会主动读取任何flink-conf.yaml的。需要配置环境变量FLINK_HOME，将相关配置写入$FLINK_HOME/conf/flink-conf.yaml里，并且只有在提交job时候(flink run、remote模式或者yarn模式)才会去读取flink-conf.yaml里的内容。
如果执意要在local模式下尝试，可以通过以下代码: from pyflink.java_gateway import get_gateway System = get_gateway().jvm.System 拿到java中的System对象，然后按照java中的方式进行配置。*来自志愿者整理的flink
2021-12-06 10:11:46赞同 展开评论
问答分类：
相关问答