kafka-connect-mqtt-0.4.0.jar

<dependency>
	<groupId>com.datamountaineer</groupId>
	<artifactId>kafka-connect-mqtt</artifactId>
	<version>0.4.0</version>
</dependency>

com.datamountaineer:kafka-connect-mqtt:0.4.0

<?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-mqtt</artifactId>

  <version>0.4.0</version>

  <name>kafka-connect-mqtt</name>

  <description>stream-reactor</description>

  <url>https://github.com/landoop/stream-reactor</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@landoop.com</email>

    </developer>

    <developer>

      <id>stheppi</id>

      <name>Stefan Bocutiu</name>

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

    </developer>

    <developer>

      <id>antwins</id>

      <name>Antonios Chalkiopoulos</name>

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

    </developer>

  </developers>

  <scm>

    <connection>scm:git:https://github.com/landoop/stream-reactor.git</connection>

    <developerConnection>scm:git:git@github.com:landoop/stream-reactor.git</developerConnection>

    <url>https://github.com/landoop/stream-reactor.git</url>

  </scm>

  <dependencies>

    <dependency>

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

      <artifactId>scala-library</artifactId>

      <version>2.11.7</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

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

      <artifactId>scala-compiler</artifactId>

      <version>2.11.7</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>org.apache.kafka</groupId>

      <artifactId>connect-json</artifactId>

      <version>0.11.0.0</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>io.confluent</groupId>

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

      <version>3.3.0</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>io.confluent</groupId>

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

      <version>3.3.0</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>com.datamountaineer</groupId>

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

      <version>0.9.7</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.eclipse.paho</groupId>

      <artifactId>org.eclipse.paho.client.mqttv3</artifactId>

      <version>1.2.0</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>com.sksamuel.avro4s</groupId>

      <artifactId>avro4s-core_2.11</artifactId>

      <version>1.6.4</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>com.sksamuel.avro4s</groupId>

      <artifactId>avro4s-json_2.11</artifactId>

      <version>1.6.4</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.bouncycastle</groupId>

      <artifactId>bcprov-jdk15on</artifactId>

      <version>1.54</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.bouncycastle</groupId>

      <artifactId>bcpkix-jdk15on</artifactId>

      <version>1.54</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.bouncycastle</groupId>

      <artifactId>bcpg-jdk15on</artifactId>

      <version>1.54</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

      <groupId>org.mockito</groupId>

      <artifactId>mockito-core</artifactId>

      <version>1.10.19</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.scalacheck</groupId>

      <artifactId>scalacheck_2.11</artifactId>

      <version>1.13.4</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.scalatest</groupId>

      <artifactId>scalatest_2.11</artifactId>

      <version>3.0.1</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>junit</groupId>

      <artifactId>junit</artifactId>

      <version>4.11</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.json4s</groupId>

      <artifactId>json4s-core_2.11</artifactId>

      <version>3.5.0</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.json4s</groupId>

      <artifactId>json4s-jackson_2.11</artifactId>

      <version>3.5.0</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>io.moquette</groupId>

      <artifactId>moquette-broker</artifactId>

      <version>0.8.1</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.pegdown</groupId>

      <artifactId>pegdown</artifactId>

      <version>1.1.0</version>

      <scope>test</scope>

    </dependency>

  </dependencies>

</project>

META-INF/MANIFEST.MF
com.datamountaineer.streamreactor.connect.mqtt.connection.MqttClientConnectionFn$$anonfun$buildBaseClient$2.class
com.datamountaineer.streamreactor.connect.mqtt.connection.MqttClientConnectionFn.class
com.datamountaineer.streamreactor.connect.mqtt.connection.MqttClientConnectionFn$$anonfun$buildBaseClient$1.class
com.datamountaineer.streamreactor.connect.mqtt.connection.MqttClientConnectionFn$.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$2.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$asMap$1.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$asMap$3.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceConfig.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$asMap$5.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSinkSettings$.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSinkSettings.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$1.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$asMap$2.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceConfig$.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttConfigConstants.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$3.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$asMap$4.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSinkConfig.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttConfig.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$apply$1.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSinkSettings$$anonfun$2.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttConfigConstants$.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSinkConfig$.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSinkSettings$$anonfun$1.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttConfig$.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttConfigBase.class
com.datamountaineer.streamreactor.connect.mqtt.config.MqttSourceSettings$$anonfun$apply$1$$anonfun$4.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$start$3.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$start$1.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$start$5.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$8.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$start$2.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$9.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$start$4.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$7.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$5.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSSLSocketFactory.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$stop$1.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$1.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSSLSocketFactory$.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector$$anonfun$taskConfigs$1$$anonfun$apply$2.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$3.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$3.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$4.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$6.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector$$anonfun$taskConfigs$1.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$1$$anonfun$2.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask$$anonfun$1.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceTask.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttManager$$anonfun$2.class
com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector$$anonfun$taskConfigs$1$$anonfun$apply$1.class
com.datamountaineer.streamreactor.connect.mqtt.sink.MqttWriter$$anonfun$2.class
com.datamountaineer.streamreactor.connect.mqtt.sink.MqttSinkTask$$anonfun$put$2.class
com.datamountaineer.streamreactor.connect.mqtt.sink.MqttWriter$$anonfun$3$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$3.class
com.datamountaineer.streamreactor.connect.mqtt.sink.MqttWriter$$anonfun$3.class
com.datamountaineer.streamreactor.connect.mqtt.sink.MqttWriter$$anonfun$3$$anonfun$apply$1$$anonfun$apply$2$$anonfun$apply$6.class
com.datamountaineer.streamreactor.connect.mqtt.sink.MqttWriter$$anonfun$1.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)