at org.apache.bookkeeper.discover.ZKRegistrationManager.getClusterInstanceId(ZKRegistrationManager.java:387)~[org.apache.bookkeeper-bookkeeper-server-4.7.2.jar:4.7.2] at org.apache.bookkeeper.bookie....
Pulsar通过BookKeeper来存储消息,保证消息不会丢失(BookKeeper:A scalable,fault-tolerant,and low-latency storage service optimized for real-time workloads)。架构 Pulsar采用“存储和服务分离”的两层架构...