返回到文章

采纳

编辑于 3年前

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

kafka

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对用户授权之后也不行。