-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/5964/
-----------------------------------------------------------
Review request for bookkeeper.
Description
-------
currently, ZkTopicManager use zookeeper ephemeral node to store the owner
information of a topic. so the znode will disappear when the owner hub server
is down, the leader election is quite simple based on this model.
but for most key-value storage, there is no similar concepts like ephemeral
node, but just providing versioned writes. so it would be better to provide a
topic manager using versioned writes.
This addresses bug BOOKKEEPER-259.
https://issues.apache.org/jira/browse/BOOKKEEPER-259
Diffs
-----
hedwig-protocol/src/main/java/org/apache/hedwig/exceptions/PubSubException.java
750471b
hedwig-protocol/src/main/java/org/apache/hedwig/protocol/PubSubProtocol.java
330441d
hedwig-protocol/src/main/protobuf/PubSubProtocol.proto d29cfe9
hedwig-server/src/main/java/org/apache/hedwig/server/common/ServerConfiguration.java
cf52ae8
hedwig-server/src/main/java/org/apache/hedwig/server/meta/MetadataManagerFactory.java
21b4577
hedwig-server/src/main/java/org/apache/hedwig/server/meta/TopicOwnershipManager.java
PRE-CREATION
hedwig-server/src/main/java/org/apache/hedwig/server/meta/ZkMetadataManagerFactory.java
8a850af
hedwig-server/src/main/java/org/apache/hedwig/server/netty/PubSubServer.java
b0e8e07
hedwig-server/src/main/java/org/apache/hedwig/server/topics/HubInfo.java
PRE-CREATION
hedwig-server/src/main/java/org/apache/hedwig/server/topics/HubLoad.java
PRE-CREATION
hedwig-server/src/main/java/org/apache/hedwig/server/topics/HubServerManager.java
PRE-CREATION
hedwig-server/src/main/java/org/apache/hedwig/server/topics/MMTopicManager.java
PRE-CREATION
hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkHubServerManager.java
PRE-CREATION
hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkTopicManager.java
f92101a
hedwig-server/src/test/java/org/apache/hedwig/server/meta/TestMetadataManager.java
6ab704f
hedwig-server/src/test/java/org/apache/hedwig/server/meta/TestMetadataManagerFactory.java
412e848
hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestHubInfo.java
PRE-CREATION
hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestHubLoad.java
PRE-CREATION
hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestMMTopicManager.java
PRE-CREATION
hedwig-server/src/test/java/org/apache/hedwig/server/topics/TestZkTopicManager.java
8c7cbd2
Diff: https://reviews.apache.org/r/5964/diff/
Testing
-------
Thanks,
Sijie Guo
