Author: kwright
Date: Fri Oct 13 12:53:54 2023
New Revision: 1912939
URL: http://svn.apache.org/viewvc?rev=1912939&view=rev
Log:
Pull up Kafka test fix from trunk
Modified:
manifoldcf/branches/release-2.26-branch/ (props changed)
manifoldcf/branches/release-2.26-branch/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java
Propchange: manifoldcf/branches/release-2.26-branch/
------------------------------------------------------------------------------
Merged /manifoldcf/trunk:r1912938
Modified:
manifoldcf/branches/release-2.26-branch/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java
URL:
http://svn.apache.org/viewvc/manifoldcf/branches/release-2.26-branch/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java?rev=1912939&r1=1912938&r2=1912939&view=diff
==============================================================================
---
manifoldcf/branches/release-2.26-branch/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java
(original)
+++
manifoldcf/branches/release-2.26-branch/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java
Fri Oct 13 12:53:54 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();
}