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
对用户授权之后也不行。
你这是开启kuberos认证了吧。
你为啥不提前使用命令行,在集群中新建主题呢?
你的答案