Pulsar initialize-cluster-metadata have Operation 106 is unknown

[luhea]

Hello,I test a pulsar cluster use RaftKeeper.i deploy a RaftKeeper cluser with 3 node，I just modify configure id & host under bin/pulsar initialize-cluster-metadata --cluster pulsar-test --metadata-store zk:ip1:8101,ip2:8101,ip3:8101 -configuration-metadata-store zk:ip1:8101,ip2:8101,ip3:8101 --web-service-url xxx --web-service-url-tls xx --broker-service-url xxx --broker-service-url-tls xxx i have a error in RaftKeeper log：

2023.04.03 18:46:25.024026 [ 20125 ] {} <Error> ConnectionHandler: Error processing session 0x1 request.: Code: 999, e.displayText() = Coordination::Exception: Operation 106 is unknown (Unimplemented), Stack trace (when copying this message, always include the lines below):

0. /data1/home/wujianchao/project/jd/raftkeeper/contrib/libcxx/include/exception:133: Poco::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator > const&, int) @ 0x9fdd8c in /usr/local/RaftKeeper/lib/raftkeeper
1. /data1/home/wujianchao/project/jd/raftkeeper/src/Common/Exception.cpp:56: RK::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator > const&, int, bool) @ 0x6e9cd1 in /usr/local/RaftKeeper/lib/raftkeeper
2. /data1/home/wujianchao/project/jd/raftkeeper/src/Common/ZooKeeper/IKeeper.cpp:26: Coordination::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator > const&, Coordination::Error, int) @ 0x8e8db6 in /usr/local/RaftKeeper/lib/raftkeeper
3. /data1/home/wujianchao/project/jd/raftkeeper/contrib/libcxx/include/string:1444: Coordination::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator > const&, Coordination::Error) @ 0x8e8fc0 in /usr/local/RaftKeeper/lib/raftkeeper
4. /data1/home/wujianchao/project/jd/raftkeeper/src/Common/ZooKeeper/ZooKeeperConstants.cpp:0: Coordination::getOpNum(int) @ 0x8fa42e in /usr/local/RaftKeeper/lib/raftkeeper
5. /data1/home/wujianchao/project/jd/raftkeeper/src/Common/ZooKeeper/ZooKeeperIO.cpp:126: Coordination::read(Coordination::OpNum&, RK::ReadBuffer&) @ 0x8fac1c in /usr/local/RaftKeeper/lib/raftkeeper
6. /data1/home/wujianchao/project/jd/raftkeeper/src/Service/ConnectionHandler.cpp:615: RK::ConnectionHandler::receiveRequest(int) @ 0x75d876 in /usr/local/RaftKeeper/lib/raftkeeper
7. /data1/home/wujianchao/project/jd/raftkeeper/src/Service/ConnectionHandler.cpp:0: RK::ConnectionHandler::onSocketReadable(Poco::AutoPtrRK::ReadableNotification const&) @ 0x758269 in /usr/local/RaftKeeper/lib/raftkeeper
8. /data1/home/wujianchao/project/jd/raftkeeper/contrib/poco/Foundation/include/Poco/AutoPtr.h:96: Poco::NObserver<RK::ConnectionHandler, RK::ReadableNotification>::notify(Poco::Notification*) const @ 0x761f49 in /usr/local/RaftKeeper/lib/raftkeeper
9. /data1/home/wujianchao/project/jd/raftkeeper/contrib/libcxx/include/iterator:1496: Poco::NotificationCenter::postNotification(Poco::AutoPtrPoco::Notification) @ 0xa2b786 in /usr/local/RaftKeeper/lib/raftkeeper
10. /data1/home/wujianchao/project/jd/raftkeeper/contrib/poco/Foundation/include/Poco/AutoPtr.h:96: RK::SocketNotifier::dispatch(RK::SocketNotification*) @ 0x81a9b7 in /usr/local/RaftKeeper/lib/raftkeeper
11. /data1/home/wujianchao/project/jd/raftkeeper/src/Service/SocketReactor.cpp:292: RK::SocketReactor::dispatch(Poco::AutoPtrRK::SocketNotifier&, RK::SocketNotification*) @ 0x818355 in /usr/local/RaftKeeper/lib/raftkeeper
12. /data1/home/wujianchao/project/jd/raftkeeper/contrib/libcxx/include/atomic:1072: RK::SocketReactor::run() @ 0x816ca0 in /usr/local/RaftKeeper/lib/raftkeeper
13. /data1/home/wujianchao/project/jd/raftkeeper/contrib/poco/Foundation/src/Thread_POSIX.cpp:373: Poco::ThreadImpl::runnableEntry(void*) @ 0xa5cd55 in /usr/local/RaftKeeper/lib/raftkeeper
14. start_thread @ 0x7ea5 in /usr/lib64/libpthread-2.17.so
15. __clone @ 0xfeb0d in /usr/lib64/libc-2.17.so (version v2.0.1)

[nicelulu]

@luhea Hi, if the RaftKeeper 3 node cluster setup is fine. Operation 106 is an AddWatch type request, and the current version of RaftKeeper does not support processing AddWatch type requests. It only supports adding watch when commands such as Get and List are used.

By the way, which version of zookeeper is your pulsar using. RaftKeeper is considering supporting more commands like AddWatch and some features in subsequent versions.

[luhea]

@luhea Hi, if the RaftKeeper 3 node cluster setup is fine. Operation 106 is an AddWatch type request, and the current version of RaftKeeper does not support processing AddWatch type requests. It only supports adding watch when commands such as Get and List are used.

By the way, which version of zookeeper is your pulsar using. RaftKeeper is considering supporting more commands like AddWatch and some features in subsequent versions

@luhea Hi, if the RaftKeeper 3 node cluster setup is fine. Operation 106 is an AddWatch type request, and the current version of RaftKeeper does not support processing AddWatch type requests. It only supports adding watch when commands such as Get and List are used.

By the way, which version of zookeeper is your pulsar using. RaftKeeper is considering supporting more commands like AddWatch and some features in subsequent versions.

pulsar version is latest is 2.11.0 and 2.11.0 pulsar's lib depend org.apache.zookeeper-zookeeper-3.8.0.jar org.apache.zookeeper-zookeeper-jute-3.8.0.jar org.apache.zookeeper-zookeeper-prometheus-metrics-3.8.0.jar

[JackyWoo]

We will add the command in the next version.

[JackyWoo]

@luhea Now RaftKeepr can run with ClickHouse an HBase. We would like it work with Pulsar. In the next we will do some researching.