You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2023/10/13 12:53:05 UTC

svn commit: r1912938 - /manifoldcf/trunk/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java

Author: kwright
Date: Fri Oct 13 12:53:05 2023
New Revision: 1912938

URL: http://svn.apache.org/viewvc?rev=1912938&view=rev
Log:
Fix kafka test build error

Modified:
    manifoldcf/trunk/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java

Modified: manifoldcf/trunk/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java
URL: http://svn.apache.org/viewvc/manifoldcf/trunk/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java?rev=1912938&r1=1912937&r2=1912938&view=diff
==============================================================================
--- manifoldcf/trunk/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java (original)
+++ manifoldcf/trunk/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java Fri Oct 13 12:53:05 2023
@@ -20,6 +20,7 @@ import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.util.Properties;
 import org.apache.zookeeper.server.ServerConfig;
+import org.apache.zookeeper.server.admin.AdminServer.AdminServerException;
 import org.apache.zookeeper.server.ZooKeeperServerMain;
 import org.apache.zookeeper.server.quorum.QuorumPeerConfig;
 
@@ -43,10 +44,14 @@ public class ZooKeeperLocal {
       public void run() {
         try {
           zooKeeperServer.runFromConfig(configuration);
+        } catch (AdminServerException e) {
+          System.out.println("ZooKeeper Failed");
+          e.printStackTrace(System.err);
         } catch (IOException e) {
           System.out.println("ZooKeeper Failed");
           e.printStackTrace(System.err);
         }
+        
       }
     }.start();
   }