Added: manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/NavigationHSQLDBUI.java URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/NavigationHSQLDBUI.java?rev=1708553&view=auto ============================================================================== --- manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/NavigationHSQLDBUI.java (added) +++ manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/NavigationHSQLDBUI.java Wed Oct 14 07:18:37 2015 @@ -0,0 +1,225 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.manifoldcf.agents.output.kafka; + +import java.util.Locale; + +import org.apache.manifoldcf.core.tests.HTMLTester; +import org.junit.Test; + +public class NavigationHSQLDBUI extends BaseUIHSQLDB { + + @Test + public void createConnectionsAndJob() + throws Exception { + testerInstance.newTest(Locale.US); + + HTMLTester.Window window; + HTMLTester.Link link; + HTMLTester.Form form; + HTMLTester.Textarea textarea; + HTMLTester.Selectbox selectbox; + HTMLTester.Button button; + HTMLTester.Radiobutton radiobutton; + HTMLTester.Loop loop; + + window = testerInstance.openMainWindow("http://localhost:8346/mcf-crawler-ui/index.jsp";); + + // Login + form = window.findForm(testerInstance.createStringDescription("loginform")); + textarea = form.findTextarea(testerInstance.createStringDescription("userID")); + textarea.setValue(testerInstance.createStringDescription("admin")); + textarea = form.findTextarea(testerInstance.createStringDescription("password")); + textarea.setValue(testerInstance.createStringDescription("admin")); + button = window.findButton(testerInstance.createStringDescription("Login")); + button.click(); + window = testerInstance.findWindow(null); + + // Define an output connection via the UI + link = window.findLink(testerInstance.createStringDescription("List output connections")); + link.click(); + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Add an output connection")); + link.click(); + // Fill in a name + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editconnection")); + textarea = form.findTextarea(testerInstance.createStringDescription("connname")); + textarea.setValue(testerInstance.createStringDescription("MyOutputConnection")); + link = window.findLink(testerInstance.createStringDescription("Type tab")); + link.click(); + // Select a type + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editconnection")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("classname")); + selectbox.selectValue(testerInstance.createStringDescription("org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector")); + button = window.findButton(testerInstance.createStringDescription("Continue to next page")); + button.click(); + // Visit the Throttling tab + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Throttling tab")); + link.click(); + // Go back to the Name tab + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Name tab")); + link.click(); + // Parameters tab + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Parameters tab")); + link.click(); + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editconnection")); + textarea = form.findTextarea(testerInstance.createStringDescription("ip")); + textarea.setValue(testerInstance.createStringDescription("localhost")); + textarea = form.findTextarea(testerInstance.createStringDescription("port")); + textarea.setValue(testerInstance.createStringDescription("9092")); + textarea = form.findTextarea(testerInstance.createStringDescription("topic")); + textarea.setValue(testerInstance.createStringDescription("topic")); + + // Go back to the Name tab + link = window.findLink(testerInstance.createStringDescription("Name tab")); + link.click(); + // Now save the connection. + window = testerInstance.findWindow(null); + button = window.findButton(testerInstance.createStringDescription("Save this output connection")); + button.click(); + + // Define a repository connection via the UI + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("List repository connections")); + link.click(); + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Add a connection")); + link.click(); + // Fill in a name + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editconnection")); + textarea = form.findTextarea(testerInstance.createStringDescription("connname")); + textarea.setValue(testerInstance.createStringDescription("MyRepositoryConnection")); + link = window.findLink(testerInstance.createStringDescription("Type tab")); + link.click(); + // Select a type + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editconnection")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("classname")); + selectbox.selectValue(testerInstance.createStringDescription("org.apache.manifoldcf.crawler.tests.TestingRepositoryConnector")); + button = window.findButton(testerInstance.createStringDescription("Continue to next page")); + button.click(); + // Visit the Throttling tab + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Throttling tab")); + link.click(); + window = testerInstance.findWindow(null); + // Now save the connection. + button = window.findButton(testerInstance.createStringDescription("Save this connection")); + button.click(); + + // Create a job + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("List jobs")); + link.click(); + // Add a job + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Add a job")); + link.click(); + // Fill in a name + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editjob")); + textarea = form.findTextarea(testerInstance.createStringDescription("description")); + textarea.setValue(testerInstance.createStringDescription("MyJob")); + link = window.findLink(testerInstance.createStringDescription("Connection tab")); + link.click(); + // Select the connections + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editjob")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("output_connectionname")); + selectbox.selectValue(testerInstance.createStringDescription("MyOutputConnection")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("output_precedent")); + selectbox.selectValue(testerInstance.createStringDescription("-1")); + button = window.findButton(testerInstance.createStringDescription("Add an output")); + button.click(); + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editjob")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("connectionname")); + selectbox.selectValue(testerInstance.createStringDescription("MyRepositoryConnection")); + button = window.findButton(testerInstance.createStringDescription("Continue to next screen")); + button.click(); + // Visit all the tabs. Scheduling tab first + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Scheduling tab")); + link.click(); + window = testerInstance.findWindow(null); + form = window.findForm(testerInstance.createStringDescription("editjob")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("dayofweek")); + selectbox.selectValue(testerInstance.createStringDescription("0")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("hourofday")); + selectbox.selectValue(testerInstance.createStringDescription("1")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("minutesofhour")); + selectbox.selectValue(testerInstance.createStringDescription("30")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("monthofyear")); + selectbox.selectValue(testerInstance.createStringDescription("11")); + selectbox = form.findSelectbox(testerInstance.createStringDescription("dayofmonth")); + selectbox.selectValue(testerInstance.createStringDescription("none")); + textarea = form.findTextarea(testerInstance.createStringDescription("duration")); + textarea.setValue(testerInstance.createStringDescription("120")); + button = window.findButton(testerInstance.createStringDescription("Add new schedule record")); + button.click(); + window = testerInstance.findWindow(null); + // MHL + // Save the job + button = window.findButton(testerInstance.createStringDescription("Save this job")); + button.click(); + + // Delete the job + window = testerInstance.findWindow(null); + HTMLTester.StringDescription jobID = window.findMatch(testerInstance.createStringDescription("<!--jobid=(.*?)-->"), 0); + testerInstance.printValue(jobID); + link = window.findLink(testerInstance.createStringDescription("Delete this job")); + link.click(); + + // Wait for the job to go away + loop = testerInstance.beginLoop(120); + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Manage jobs")); + link.click(); + window = testerInstance.findWindow(null); + HTMLTester.StringDescription isJobNotPresent = window.isNotPresent(jobID); + testerInstance.printValue(isJobNotPresent); + loop.breakWhenTrue(isJobNotPresent); + loop.endLoop(); + + // Delete the repository connection + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("List repository connections")); + link.click(); + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Delete MyRepositoryConnection")); + link.click(); + + // Delete the output connection + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("List output connections")); + link.click(); + window = testerInstance.findWindow(null); + link = window.findLink(testerInstance.createStringDescription("Delete MyOutputConnection")); + link.click(); + + testerInstance.executeTest(); + } + +}
Added: manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java?rev=1708553&view=auto ============================================================================== --- manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java (added) +++ manifoldcf/branches/CONNECTORS-1162/connectors/kafka/connector/src/test/java/org/apache/manifoldcf/agents/output/kafka/ZooKeeperLocal.java Wed Oct 14 07:18:37 2015 @@ -0,0 +1,37 @@ +package org.apache.manifoldcf.agents.output.kafka; + +import java.io.FileNotFoundException; +import java.io.IOException; +import java.util.Properties; +import org.apache.zookeeper.server.ServerConfig; +import org.apache.zookeeper.server.ZooKeeperServerMain; +import org.apache.zookeeper.server.quorum.QuorumPeerConfig; + +public class ZooKeeperLocal { + + ZooKeeperServerMain zooKeeperServer; + + public ZooKeeperLocal(Properties zkProperties) throws FileNotFoundException, IOException { + QuorumPeerConfig quorumConfiguration = new QuorumPeerConfig(); + try { + quorumConfiguration.parseProperties(zkProperties); + } catch (Exception e) { + throw new RuntimeException(e); + } + + zooKeeperServer = new ZooKeeperServerMain(); + final ServerConfig configuration = new ServerConfig(); + configuration.readFrom(quorumConfiguration); + + new Thread() { + public void run() { + try { + zooKeeperServer.runFromConfig(configuration); + } catch (IOException e) { + System.out.println("ZooKeeper Failed"); + e.printStackTrace(System.err); + } + } + }.start(); + } +} Added: manifoldcf/branches/CONNECTORS-1162/connectors/kafka/pom.xml URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1162/connectors/kafka/pom.xml?rev=1708553&view=auto ============================================================================== --- manifoldcf/branches/CONNECTORS-1162/connectors/kafka/pom.xml (added) +++ manifoldcf/branches/CONNECTORS-1162/connectors/kafka/pom.xml Wed Oct 14 07:18:37 2015 @@ -0,0 +1,460 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the LiceFnse. +--> + +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + <parent> + <groupId>org.apache.manifoldcf</groupId> + <artifactId>mcf-connectors</artifactId> + <version>2.2-SNAPSHOT</version> + </parent> + <modelVersion>4.0.0</modelVersion> + + <properties> + <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> + <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> + </properties> + + <artifactId>mcf-kafka-connector</artifactId> + <name>ManifoldCF - Connectors - Kafka</name> + + <build> + <defaultGoal>integration-test</defaultGoal> + <sourceDirectory>${basedir}/connector/src/main/java</sourceDirectory> + <testSourceDirectory>${basedir}/connector/src/test/java</testSourceDirectory> + <resources> + <resource> + <directory>${basedir}/connector/src/main/native2ascii</directory> + <includes> + <include>**/*.properties</include> + </includes> + </resource> + <resource> + <directory>${basedir}/connector/src/main/resources</directory> + <includes> + <include>**/*.html</include> + <include>**/*.js</include> + </includes> + </resource> + </resources> + <testResources> + <testResource> + <directory>${basedir}/connector/src/test/resources</directory> + </testResource> + </testResources> + + <plugins> + + <plugin> + <groupId>org.codehaus.mojo</groupId> + <artifactId>native2ascii-maven-plugin</artifactId> + <version>1.0-beta-1</version> + <configuration> + <workDir>target/classes</workDir> + </configuration> + <executions> + <execution> + <id>native2ascii-utf8</id> + <goals> + <goal>native2ascii</goal> + </goals> + <configuration> + <encoding>UTF8</encoding> + <includes> + <include>**/*.properties</include> + </includes> + </configuration> + </execution> + </executions> + </plugin> + + <!-- Test plugin configuration --> + <plugin> + <artifactId>maven-dependency-plugin</artifactId> + <executions> + <execution> + <id>copy-war</id> + <phase>generate-resources</phase> + <goals> + <goal>copy</goal> + </goals> + <configuration> + <outputDirectory>target/dependency</outputDirectory> + <artifactItems> + <artifactItem> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-crawler-ui</artifactId> + <version>${project.version}</version> + <type>war</type> + <overWrite>false</overWrite> + <destFileName>mcf-crawler-ui.war</destFileName> + </artifactItem> + <artifactItem> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-api-service</artifactId> + <version>${project.version}</version> + <type>war</type> + <overWrite>false</overWrite> + <destFileName>mcf-api-service.war</destFileName> + </artifactItem> + <artifactItem> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-authority-service</artifactId> + <version>${project.version}</version> + <type>war</type> + <overWrite>false</overWrite> + <destFileName>mcf-authority-service.war</destFileName> + </artifactItem> + <artifactItem> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-crawler-ui</artifactId> + <version>${project.version}</version> + <type>war</type> + <overWrite>false</overWrite> + <destFileName>mcf-crawler-ui.war</destFileName> + </artifactItem> + </artifactItems> + </configuration> + </execution> + </executions> + </plugin> + + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-surefire-plugin</artifactId> + <configuration> + <excludes> + <exclude>**/*Postgresql*.java</exclude> + <exclude>**/*MySQL*.java</exclude> + </excludes> + <forkMode>always</forkMode> + <workingDirectory>target/test-output</workingDirectory> + </configuration> + </plugin> + + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-failsafe-plugin</artifactId> + <version>2.12.3</version> + <configuration> + <skipTests>${skipITs}</skipTests> + <systemPropertyVariables> + <crawlerWarPath>../dependency/mcf-crawler-ui.war</crawlerWarPath> + <authorityserviceWarPath>../dependency/mcf-authority-service.war</authorityserviceWarPath> + <apiWarPath>../dependency/mcf-api-service.war</apiWarPath> + </systemPropertyVariables> + <excludes> + <exclude>**/*Postgresql*.java</exclude> + <exclude>**/*MySQL*.java</exclude> + </excludes> + <forkMode>always</forkMode> + <workingDirectory>target/test-output</workingDirectory> + </configuration> + <executions> + <execution> + <id>integration-test</id> + <goals> + <goal>integration-test</goal> + </goals> + </execution> + <execution> + <id>verify</id> + <goals> + <goal>verify</goal> + </goals> + </execution> + </executions> + </plugin> + + </plugins> + </build> + + <dependencies> + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-core</artifactId> + <version>${project.version}</version> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-crawler-ui</artifactId> + <version>${project.version}</version> + <type>war</type> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-connector-common</artifactId> + <version>${project.version}</version> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-agents</artifactId> + <version>${project.version}</version> + </dependency> + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-pull-agent</artifactId> + <version>${project.version}</version> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-agents</artifactId> + <version>${project.version}</version> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-ui-core</artifactId> + <version>${project.version}</version> + </dependency> + + <dependency> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka-clients</artifactId> + <version>0.8.2.1</version> + </dependency> + <dependency> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka_2.11</artifactId> + <version>0.8.2.1</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.scala-lang</groupId> + <artifactId>scala-library</artifactId> + <version>2.11.0</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>net.sf.jopt-simple</groupId> + <artifactId>jopt-simple</artifactId> + <version>3.2</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.scala-lang.modules</groupId> + <artifactId>scala-xml_2.11</artifactId> + <version>1.0.4</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.scala-lang.modules</groupId> + <artifactId>scala-parser-combinators_2.11</artifactId> + <version>1.0.4</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>com.yammer.metrics</groupId> + <artifactId>metrics-core</artifactId> + <version>2.2.0</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-agents</artifactId> + <version>${project.version}</version> + <type>test-jar</type> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-pull-agent</artifactId> + <version>${project.version}</version> + <type>test-jar</type> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>postgresql</groupId> + <artifactId>postgresql</artifactId> + <version>${postgresql.version}</version> + <scope>test</scope> + </dependency> + + <!-- Testing dependencies --> + + <dependency> + <groupId>org.apache.commons</groupId> + <artifactId>commons-lang3</artifactId> + <version>3.4</version> + </dependency> + + <dependency> + <groupId>org.mockito</groupId> + <artifactId>mockito-core</artifactId> + <version>${mockito.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>com.github.tomakehurst</groupId> + <artifactId>wiremock</artifactId> + <version>${wiremock.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <version>${junit.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-core</artifactId> + <version>${project.version}</version> + <type>test-jar</type> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.hsqldb</groupId> + <artifactId>hsqldb</artifactId> + <version>${hsqldb.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>mysql</groupId> + <artifactId>mysql-connector-java</artifactId> + <version>${mysql.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-api-service</artifactId> + <version>${project.version}</version> + <type>war</type> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>${project.groupId}</groupId> + <artifactId>mcf-authority-service</artifactId> + <version>${project.version}</version> + <type>war</type> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-server</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-util</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-webapp</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-servlet</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-http</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-io</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-security</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-continuation</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.eclipse.jetty</groupId> + <artifactId>jetty-xml</artifactId> + <version>${jetty.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.mortbay.jetty</groupId> + <artifactId>jsp-api-2.1-glassfish</artifactId> + <version>${glassfish.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.mortbay.jetty</groupId> + <artifactId>jsp-2.1-glassfish</artifactId> + <version>${glassfish.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-api</artifactId> + <version>${slf4j.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-simple</artifactId> + <version>${slf4j.version}</version> + <scope>test</scope> + </dependency> + + <dependency> + <groupId>org.apache.zookeeper</groupId> + <artifactId>zookeeper</artifactId> + <version>${zookeeper.version}</version> + <scope>test</scope> + </dependency> + </dependencies> +</project> Modified: manifoldcf/branches/CONNECTORS-1162/connectors/pom.xml URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1162/connectors/pom.xml?rev=1708553&r1=1708552&r2=1708553&view=diff ============================================================================== --- manifoldcf/branches/CONNECTORS-1162/connectors/pom.xml (original) +++ manifoldcf/branches/CONNECTORS-1162/connectors/pom.xml Wed Oct 14 07:18:37 2015 @@ -67,6 +67,7 @@ <module>searchblox</module> <module>confluence</module> <module>amazons3</module> + <module>kafka</module> </modules> </project> Modified: manifoldcf/branches/CONNECTORS-1162/framework/build.xml URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1162/framework/build.xml?rev=1708553&r1=1708552&r2=1708553&view=diff ============================================================================== --- manifoldcf/branches/CONNECTORS-1162/framework/build.xml (original) +++ manifoldcf/branches/CONNECTORS-1162/framework/build.xml Wed Oct 14 07:18:37 2015 @@ -1411,6 +1411,8 @@ <include name="pdfbox*.jar"/> <include name="fontbox*.jar"/> <include name="jempbox*.jar"/> + <include name="kafka*.jar"/> + <include name="zookeeper*.jar"/> <include name="bcmail-jdk15*.jar"/> <include name="bcprov-jdk15*.jar"/> <include name="xmlbeans*.jar"/>
