KeeperErrorCode = 未针对 /kafka-manager/mutex 实现

Question

尝试在K8s集群的“CMAK”中添加新集群时，提示以下错误。

Yikes! KeeperErrorCode = Unimplemented for /kafka-manager/mutex Try again.

我的集群配置如下，

zookeeper: wurstmeister/zookeeper
kafka-manager: kafkamanager/kafka-manager:3.0.0.4
kafka: wurstmeister/kafka:2.12-2.4.1

Answer 1

我可以按照以下步骤解决它。

1. 连接到 k8s 中的“zookeeper”容器

   k exec -it podid -- bash

2. 与zookeeper cli连接，

   ./bin/zkCli.sh

3. 确保它已经创建了“kafka-manager”路径。如果不存在，则首先尝试在“kafka-manager”中创建集群。

   ls /kafka-manager

4. 点击以下命令来创建后续路径，

   创建/kafka-manager/mutex“”

   创建/kafka-manager/mutex/locks“”

   创建/kafka-manager/mutex/leases“”

5. 现在尝试再次创建集群。

输出会是这样的，

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
[zk: localhost:2181(CONNECTED) 0] ls /kafka-manager
[configs, deleteClusters, clusters]
[zk: localhost:2181(CONNECTED) 1] create /kafka-manager/mutex ""
Created /kafka-manager/mutex
[zk: localhost:2181(CONNECTED) 2] create /kafka-manager/mutex/locks ""
Created /kafka-manager/mutex/locks
[zk: localhost:2181(CONNECTED) 3] create /kafka-manager/mutex/leases ""
Created /kafka-manager/mutex/leases
[zk: localhost:2181(CONNECTED) 4]

这里提到了原始答案， https://github.com/yahoo/CMAK/issues/731#issuecomment-643880544