kafka-connect-common-0.3.5.jar

<dependency>
	<groupId>com.datamountaineer</groupId>
	<artifactId>kafka-connect-common</artifactId>
	<version>0.3.5</version>
</dependency>

com.datamountaineer:kafka-connect-common:0.3.5

<?xml version="1.0" encoding="UTF-8"?>

<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

  <modelVersion>4.0.0</modelVersion>

  <groupId>com.datamountaineer</groupId>

  <artifactId>kafka-connect-common</artifactId>

  <version>0.3.5</version>

  <name>kafka-connect-common</name>

  <description>kafka-connect-common</description>

  <url>https://github.com/datamountaineer/kafka-connect-common</url>

  <licenses>

    <license>

      <name>Apache License 2.0</name>

      <url>http://www.apache.org/licenses/LICENSE-2.0.html</url>

      <distribution>repo</distribution>

    </license>

  </licenses>

  <developers>

    <developer>

      <id>andrewstevenson</id>

      <name>Andrew Stevenson</name>

      <email>andrew@datamountaineer.com</email>

    </developer>

    <developer>

      <id>stheppi</id>

      <name>Stefan Bocutiu</name>

      <email>stefan@datamountaineer.com</email>

    </developer>

    <developer>

      <id>Antwnis</id>

      <name>Antonios Chalkiopoulos</name>

      <email>antonios@datamountaineer.com</email>

    </developer>

  </developers>

  <scm>

    <connection>scm:git:https://github.com/datamountaineer/kafka-connect-common.git</connection>

    <developerConnection>scm:git:git@github.com:datamountaineer/kafka-connect-common.git</developerConnection>

    <url>https://github.com/datamountaineer/kafka-connect-common.git</url>

  </scm>

  <dependencies>

    <dependency>

      <groupId>junit</groupId>

      <artifactId>junit</artifactId>

      <version>4.11</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.apache.kafka</groupId>

      <artifactId>connect-json</artifactId>

      <version>0.9.0.1</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.scalatest</groupId>

      <artifactId>scalatest_2.11</artifactId>

      <version>2.2.6</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.apache.curator</groupId>

      <artifactId>curator-test</artifactId>

      <version>3.1.0</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.scala-lang</groupId>

      <artifactId>scala-compiler</artifactId>

      <version>2.11.7</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>io.confluent</groupId>

      <artifactId>kafka-connect-avro-converter</artifactId>

      <version>2.0.1</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.mockito</groupId>

      <artifactId>mockito-all</artifactId>

      <version>1.10.19</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.scalacheck</groupId>

      <artifactId>scalacheck_2.11</artifactId>

      <version>1.11.1</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.pegdown</groupId>

      <artifactId>pegdown</artifactId>

      <version>1.1.0</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>com.google.guava</groupId>

      <artifactId>guava</artifactId>

      <version>18.0</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>com.typesafe.scala-logging</groupId>

      <artifactId>scala-logging-slf4j_2.11</artifactId>

      <version>2.1.2</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>io.confluent</groupId>

      <artifactId>kafka-schema-registry</artifactId>

      <version>2.0.1</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.scala-lang</groupId>

      <artifactId>scala-library</artifactId>

      <version>2.11.7</version>

      <scope>compile</scope>

    </dependency>

  </dependencies>

</project>

META-INF/MANIFEST.MF
com.datamountaineer.streamreactor.connect.concurrent.ExecutorExtension$.class
com.datamountaineer.streamreactor.connect.concurrent.ExecutorExtension$RunnableWrapper$$anon$1.class
com.datamountaineer.streamreactor.connect.concurrent.ExecutorExtension$RunnableWrapper$.class
com.datamountaineer.streamreactor.connect.concurrent.ExecutorExtension$RunnableWrapper.class
com.datamountaineer.streamreactor.connect.concurrent.ExecutorExtension.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn$$anonfun$apply$3$$anonfun$apply$1.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn$$anonfun$apply$3.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn$$anonfun$apply$4.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn$$anonfun$apply$5$$anonfun$apply$2.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn$$anonfun$apply$5.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn$$anonfun$apply$6.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn$.class
com.datamountaineer.streamreactor.connect.concurrent.FutureAwaitWithFailFastFn.class
com.datamountaineer.streamreactor.connect.config.Field$.class
com.datamountaineer.streamreactor.connect.config.Field.class
com.datamountaineer.streamreactor.connect.config.Helpers$$anonfun$1.class
com.datamountaineer.streamreactor.connect.config.Helpers$$anonfun$buildRouteMaps$1.class
com.datamountaineer.streamreactor.connect.config.Helpers$$anonfun$pKParser$1.class
com.datamountaineer.streamreactor.connect.config.Helpers$$anonfun$splitter$1.class
com.datamountaineer.streamreactor.connect.config.Helpers$$anonfun$splitter$2.class
com.datamountaineer.streamreactor.connect.config.Helpers$$anonfun$tableTopicParser$1.class
com.datamountaineer.streamreactor.connect.config.Helpers$$anonfun$tableTopicParser$2.class
com.datamountaineer.streamreactor.connect.config.Helpers$.class
com.datamountaineer.streamreactor.connect.config.Helpers.class
com.datamountaineer.streamreactor.connect.config.RouteMapping$.class
com.datamountaineer.streamreactor.connect.config.RouteMapping.class
com.datamountaineer.streamreactor.connect.config.SSLConfig$.class
com.datamountaineer.streamreactor.connect.config.SSLConfig.class
com.datamountaineer.streamreactor.connect.config.SSLConfigContext$$anonfun$getKeyManagers$1.class
com.datamountaineer.streamreactor.connect.config.SSLConfigContext$$anonfun$getKeyManagers$2.class
com.datamountaineer.streamreactor.connect.config.SSLConfigContext$.class
com.datamountaineer.streamreactor.connect.config.SSLConfigContext.class
com.datamountaineer.streamreactor.connect.errors.ErrorHandler$$anonfun$handleTry$1.class
com.datamountaineer.streamreactor.connect.errors.ErrorHandler$class.class
com.datamountaineer.streamreactor.connect.errors.ErrorHandler.class
com.datamountaineer.streamreactor.connect.errors.ErrorPolicy$.class
com.datamountaineer.streamreactor.connect.errors.ErrorPolicy$class.class
com.datamountaineer.streamreactor.connect.errors.ErrorPolicy.class
com.datamountaineer.streamreactor.connect.errors.ErrorPolicyEnum$.class
com.datamountaineer.streamreactor.connect.errors.ErrorPolicyEnum.class
com.datamountaineer.streamreactor.connect.errors.ErrorTracker$.class
com.datamountaineer.streamreactor.connect.errors.ErrorTracker.class
com.datamountaineer.streamreactor.connect.errors.NoopErrorPolicy$.class
com.datamountaineer.streamreactor.connect.errors.NoopErrorPolicy.class
com.datamountaineer.streamreactor.connect.errors.RetryErrorPolicy$.class
com.datamountaineer.streamreactor.connect.errors.RetryErrorPolicy.class
com.datamountaineer.streamreactor.connect.errors.ThrowErrorPolicy$.class
com.datamountaineer.streamreactor.connect.errors.ThrowErrorPolicy.class
com.datamountaineer.streamreactor.connect.offsets.OffsetHandler$$anonfun$1.class
com.datamountaineer.streamreactor.connect.offsets.OffsetHandler$.class
com.datamountaineer.streamreactor.connect.offsets.OffsetHandler.class
com.datamountaineer.streamreactor.connect.queues.QueueHelpers$.class
com.datamountaineer.streamreactor.connect.queues.QueueHelpers$LinkedBlockingQueueExtension$.class
com.datamountaineer.streamreactor.connect.queues.QueueHelpers$LinkedBlockingQueueExtension.class
com.datamountaineer.streamreactor.connect.queues.QueueHelpers.class
com.datamountaineer.streamreactor.connect.rowkeys.RowKeyModeEnum$.class
com.datamountaineer.streamreactor.connect.rowkeys.RowKeyModeEnum.class
com.datamountaineer.streamreactor.connect.rowkeys.StringGenericRowKeyBuilder$.class
com.datamountaineer.streamreactor.connect.rowkeys.StringGenericRowKeyBuilder.class
com.datamountaineer.streamreactor.connect.rowkeys.StringKeyBuilder.class
com.datamountaineer.streamreactor.connect.rowkeys.StringSinkRecordKeyBuilder$$anonfun$build$1.class
com.datamountaineer.streamreactor.connect.rowkeys.StringSinkRecordKeyBuilder.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder$$anonfun$1.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder$$anonfun$2.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder$$anonfun$3.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder$$anonfun$build$2.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder$$anonfun$build$3$$anonfun$apply$1.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder$$anonfun$build$3.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder$.class
com.datamountaineer.streamreactor.connect.rowkeys.StringStructFieldsStringKeyBuilder.class
com.datamountaineer.streamreactor.connect.schemas.ConverterUtil$$anonfun$1.class
com.datamountaineer.streamreactor.connect.schemas.ConverterUtil$$anonfun$convert$1.class
com.datamountaineer.streamreactor.connect.schemas.ConverterUtil$$anonfun$convert$2.class
com.datamountaineer.streamreactor.connect.schemas.ConverterUtil$$anonfun$convert$3.class
com.datamountaineer.streamreactor.connect.schemas.ConverterUtil$$anonfun$convert$4.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)