SAMZA-1382: added Zk communication protocol version verification
authorBoris Shkolnik <boryas@apache.org>
Wed, 23 Aug 2017 00:55:54 +0000 (17:55 -0700)
committerXinyu Liu <xiliu@xiliu-ld.linkedin.biz>
Wed, 23 Aug 2017 00:55:54 +0000 (17:55 -0700)
commit80d82b6a51f6dc0b65f766b63704b30c780073ac
tree77aad034047a42e89c191eba447ad1ee363f2f7b
parent67f7214aace6f9f98492b53f0a10d703aa8706c1
SAMZA-1382: added Zk communication protocol version verification

Author: Boris Shkolnik <boryas@apache.org>
Author: Boris Shkolnik <bshkolni@linkedin.com>

Reviewers: Xinyu Liu <xinyu@apache.org>

Closes #255 from sborya/ZkCommunicationVersion
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java
samza-core/src/main/java/org/apache/samza/zk/ZkControllerImpl.java
samza-core/src/main/java/org/apache/samza/zk/ZkLeaderElector.java
samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java
samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java
samza-core/src/test/java/org/apache/samza/zk/TestZkLeaderElector.java
samza-core/src/test/java/org/apache/samza/zk/TestZkUtils.java