kafka华为集群使用api创建topic提示没有操作权限

卡布奇诺 发表于: 2021-06-24   最后更新时间: 2021-06-25 09:59:49   1,928 游览

1、华为集群,使用kafka AdminClient创建topic,使用端口号为21005(非安全端口号),提示对cluster没有操作权限。

2、使用spark-submit提交的任务,keytab 和 principal jass.conf都已经提交,可以正常消费topic和推送数据到topic,只有创建topic提示cluster无权限。

3、开源集群使用相同的代码创建topic无任何问题。

错误信息为:

java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.ClusterAuthorizationException:Cluster authorization failed

尝试的方法:

1、使用 kafka-topics.sh -creater 可以创建topic。
2、kinit -kt user.kettab user对用户授权之后也不行。

发表于 2021-06-24
添加评论

你这是开启kuberos认证了吧。

你为啥不提前使用命令行,在集群中新建主题呢?

你的答案

查看kafka相关的其他问题或提一个您自己的问题