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
我按照步骤解决了。
连接到k8s中的'zookeeper'容器
k exec -it podid -- bash
连接zookeeper cli,
./bin/zkCli.sh
确保它已经创建了 'kafka-manager' 路径。如果不存在,则先尝试在'kafka-manager'中创建集群。
ls /kafka-manager
点击以下命令创建后续路径,
创建/kafka-manager/mutex“”
创建 /kafka-manager/mutex/锁定“”
创建/kafka-manager/mutex/租约“”
现在再次尝试创建集群。
输出结果是这样的,
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
在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
我按照步骤解决了。
连接到k8s中的'zookeeper'容器
k exec -it podid -- bash
连接zookeeper cli,
./bin/zkCli.sh
确保它已经创建了 'kafka-manager' 路径。如果不存在,则先尝试在'kafka-manager'中创建集群。
ls /kafka-manager
点击以下命令创建后续路径,
创建/kafka-manager/mutex“”
创建 /kafka-manager/mutex/锁定“”
创建/kafka-manager/mutex/租约“”
现在再次尝试创建集群。
输出结果是这样的,
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