upgrade zkclient to 2.1.2

adyliu · Dec 26, 2017 · 5f2a8a2 · 5f2a8a2
1 parent 3afd7a4
commit 5f2a8a2
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 deletions.
diff --git a/.gitignore b/.gitignore
@@ -18,3 +18,4 @@ __pycache__
 *.iml
 pom-*.xml
 dist
+release
diff --git a/pom.xml b/pom.xml
@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>io.jafka</groupId>
     <artifactId>jafka</artifactId>
-    <version>3.0.3</version>
+    <version>3.0.4</version>
     <packaging>jar</packaging>
     <name>jafka</name>
     <url>https://github.com/adyliu/jafka</url>
@@ -57,7 +57,7 @@
         <dependency>
             <groupId>com.github.adyliu</groupId>
             <artifactId>zkclient</artifactId>
-            <version>2.1.1</version>
+            <version>2.1.2</version>
         </dependency>
         <dependency>
             <groupId>org.codehaus.jackson</groupId>

diff --git a/src/test/java/io/jafka/consumer/ZookeeperConsumerConnector4Test.java b/src/test/java/io/jafka/consumer/ZookeeperConsumerConnector4Test.java
@@ -107,17 +107,17 @@ public void testCreateMessageStreams() throws Exception {
             data.add(msg);
             producer.send(data);
             if(i ==0) {
-                Thread.sleep(2000L);//waiting broker register this topic
+                //Thread.sleep(2000L);//waiting broker register this topic
             }
         }
-        Thread.sleep(1000L);
+        Thread.sleep(100L);
         //
         //flush all servers
         for (Jafka jafka : jafkas) {
             flush(jafka);
         }
         //waiting for sending over
-        Thread.sleep(1000L);
+        Thread.sleep(100L);
         producer.close();
         //
         props.setProperty("groupid", "group1");
@@ -126,7 +126,7 @@ public void testCreateMessageStreams() throws Exception {
         KV<ExecutorService, ConsumerConnector> kv1 = createConsumer(props, 2, "photopark_sohu-1337926225553-6e3daba6",receiveCount);
         KV<ExecutorService, ConsumerConnector> kv2 = createConsumer(props, 2, "photopark_sohu-1337936606600-9c8a98c4",receiveCount);
 
-        Thread.sleep(3000L);
+        Thread.sleep(300L);
         KV<ExecutorService, ConsumerConnector> kv3 = createConsumer(props, 2, "photopark_sohu-1337936716354-ab3c9481",receiveCount);
         while(receiveCount.get()<messageCount) {
         }