KeeperErrorCode =未为/kafka管理器/互斥实现

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中的“动物园管理员”容器

k -it podid bash

1. 连接与动物园管理员cli，

./bin/zkCli.sh

1. 确保它已经创建了“卡夫卡-经理”路径。如果它不存在，那么首先尝试在“kafka-manager”中创建一个集群。

ls /kafka-manager

1. 按以下命令创建后续路径，

创建/kafka-manager/mutex "“

创建/kafka-manager/mutex/lock "“

创建/kafka管理器/互斥/租赁“”

1. 现在再次尝试创建集群.

输出是这样的，

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