KeeperErrorCode = /kafka-manager/mutex 未实现

KeeperErrorCode = Unimplemented for /kafka-manager/mutex

在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

我按照步骤解决了。

  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/锁定“”

    创建/kafka-manager/mutex/租约“”

  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