FusionInsight Kafka创建Topic失败原因及解决方案

一、 无权限

创建Topic会报错“ERROR org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /config/topics/topicName。

解决办法是使用具体kafkaadmin权限的用户。

二、 Quota限制

创建Topic会报错“Nodes number exceed quota limit for /config/topics/topicName”。

解决办法是：

1. 检查Kafka全部配置中Quota配置quota.number是否是250000，如果不是改为此值。
2. 同步zk配置。

FusionInsight Manager页面“集群->Zookeeper->更多->同步配置”，同步配置操作每5分钟执行一次，最多等5分钟，zk客户端执行listquota /kafka查看quota的count值是否为250000。

zk客户端查看quota值方法如下：

1. 进入FI客户端（例如/opt/hadoopclient）
2. 执行命令source bigdata_env
3. 执行命令kinit 用户名（普通模式跳过）
4. 执行sh -server zk业务IP:24002

   

三、 副本个数大于正常节点数

创建Topic会报错“ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: X larger than available brokers: X”

解决办法是：解决异常节点问题或减少副本数。

四、 客户端版本低

客户端是低版本而服务端是高版本时，创建Topic可能不会报错但是查看topic的describe信息时leader为none。原因是zk上报没有权限访问“/brokers/topics/topicName”目录，此目录下无法创建partitions目录。

解决办法是：使用与服务端对应的客户端版本。