akka-stream-kafka_2.11-0.11-M2.jar

<dependency>
	<groupId>com.typesafe.akka</groupId>
	<artifactId>akka-stream-kafka_2.11</artifactId>
	<version>0.11-M2</version>
</dependency>

com.typesafe.akka:akka-stream-kafka_2.11:0.11-M2

<?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:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0">

    <modelVersion>4.0.0</modelVersion>

    <groupId>com.typesafe.akka</groupId>

    <artifactId>akka-stream-kafka_2.11</artifactId>

    <packaging>jar</packaging>

    <description>akka-stream-kafka</description>

    <url>https://github.com/akka/reactive-kafka</url>

    <version>0.11-M2</version>

    <licenses>

        <license>

            <name>Apache License 2.0</name>

            <url>http://opensource.org/licenses/Apache-2.0</url>

            <distribution>repo</distribution>

        </license>

    </licenses>

    <name>akka-stream-kafka</name>

    <inceptionYear>2014</inceptionYear>

    <organization>

        <name>Lightbend</name>

        <url>http://www.lightbend.com</url>

    </organization>

    <scm>

        <url>git@github.com:akka/reactive-kafka.git</url>

        <connection>scm:git:git@github.com:akka/reactive-kafka.git</connection>

    </scm>

    <developers>

        <developer>

            <id>contributors</id>

            <name>Contributors</name>

            <email>akka-dev@googlegroups.com</email>

            <url>https://github.com/akka/reactive-kafka/graphs/contributors</url>

        </developer>

    </developers>

    <dependencies>

        <dependency>

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

            <artifactId>scala-library</artifactId>

            <version>2.11.8</version>

        </dependency>

        <dependency>

            <groupId>com.typesafe.akka</groupId>

            <artifactId>akka-testkit_2.11</artifactId>

            <version>2.4.3</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.typesafe.akka</groupId>

            <artifactId>akka-stream_2.11</artifactId>

            <version>2.4.3</version>

        </dependency>

        <dependency>

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

            <artifactId>kafka-clients</artifactId>

            <version>0.9.0.1</version>

        </dependency>

        <dependency>

            <groupId>org.scalatest</groupId>

            <artifactId>scalatest_2.11</artifactId>

            <version>2.2.4</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>org.reactivestreams</groupId>

            <artifactId>reactive-streams-tck</artifactId>

            <version>1.0.0</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.novocode</groupId>

            <artifactId>junit-interface</artifactId>

            <version>0.11</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

            <version>4.12</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.typesafe.akka</groupId>

            <artifactId>akka-slf4j_2.11</artifactId>

            <version>2.4.3</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.typesafe.akka</groupId>

            <artifactId>akka-stream-testkit_2.11</artifactId>

            <version>2.4.3</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>ch.qos.logback</groupId>

            <artifactId>logback-classic</artifactId>

            <version>1.1.3</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>org.slf4j</groupId>

            <artifactId>log4j-over-slf4j</artifactId>

            <version>1.7.12</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>org.mockito</groupId>

            <artifactId>mockito-core</artifactId>

            <version>1.10.19</version>

            <scope>test</scope>

        </dependency>

    </dependencies>

</project>

META-INF/MANIFEST.MF
akka.kafka.internal.ConsumerStage$CommittableOffsetImpl.class
akka.kafka.scaladsl.Consumer$ClientTopicPartition.class
akka.kafka.internal.ConsumerStage.class
akka.kafka.scaladsl.Consumer$$anonfun$1.class
akka.kafka.internal.ConsumerStage$CommittableOffsetImpl$.class
akka.kafka.internal.ProducerStage.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$6.class
akka.kafka.internal.ConsumerStage$.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$5.class
akka.kafka.scaladsl.Consumer$$anonfun$atMostOnceSource$1.class
reference.conf
akka.kafka.internal.ConfigSettings$$anonfun$parseKafkaClientsProperties$1.class
akka.kafka.internal.ConsumerStageLogic$$anonfun$1.class
akka.kafka.scaladsl.Consumer$Control.class
akka.kafka.ProducerSettings$$anonfun$1.class
akka.kafka.internal.ProducerStage$$anon$1$$anonfun$1.class
akka.kafka.internal.ProducerStage$$anon$1.class
akka.kafka.scaladsl.Consumer$Committable.class
akka.kafka.internal.ProducerStage$$anon$1$$anon$3$$anon$4.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anon$4.class
akka.kafka.internal.ConsumerStageLogic$$anonfun$postStop$2.class
akka.kafka.internal.PlainConsumerStage$$anon$2.class
akka.kafka.scaladsl.Consumer$PartitionOffset.class
akka.kafka.internal.ConsumerStageLogic$Poll$.class
akka.kafka.internal.ConsumerStage$CommittableOffsetBatchImpl$$anonfun$2.class
akka.kafka.ConsumerSettings$$anonfun$createKafkaConsumer$1.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$akka$kafka$internal$CommittableConsumerStage$$anon$$commitBatchInternal$1.class
akka.kafka.scaladsl.Consumer$.class
akka.kafka.scaladsl.Consumer.class
akka.kafka.internal.CommittableConsumerStage.class
akka.kafka.scaladsl.Consumer$CommittableOffsetBatch.class
akka.kafka.scaladsl.Consumer$CommittableOffsetBatch$.class
akka.kafka.ConsumerSettings.class
akka.kafka.ConsumerSettings$$anonfun$1.class
akka.kafka.internal.ConsumerStageLogic$$anon$5.class
akka.kafka.scaladsl.Producer$$anonfun$plainSink$1.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$7.class
akka.kafka.internal.ConsumerStageLogic$$anonfun$postStop$1.class
akka.kafka.internal.ConsumerStageLogic.class
akka.kafka.scaladsl.Consumer$CommittableOffset.class
akka.kafka.scaladsl.Producer$.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anon$3.class
akka.kafka.ProducerSettings.class
akka.kafka.scaladsl.Producer$Message$.class
akka.kafka.internal.ConfigSettings.class
akka.kafka.internal.PlainConsumerStage.class
akka.kafka.scaladsl.Producer$$anonfun$2.class
akka.kafka.internal.ConsumerStageLogic$$anonfun$9.class
akka.kafka.scaladsl.Consumer$PartitionOffset$.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$pollTimeout$1.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$4.class
akka.kafka.scaladsl.Consumer$ClientTopicPartition$.class
akka.kafka.scaladsl.Consumer$CommittableMessage.class
akka.kafka.scaladsl.Producer$$anonfun$1.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$8.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$StopTimeout$.class
akka.kafka.internal.ProducerStage$$anon$1$$anon$3.class
akka.kafka.internal.CommittableConsumerStage$$anon$1$$anonfun$scheduleCommitTimeout$1.class
akka.kafka.ProducerSettings$.class
akka.kafka.scaladsl.Consumer$Message.class
akka.kafka.internal.CommittableConsumerStage$$anon$1.class
akka.kafka.ConsumerSettings$$anonfun$getProperty$1.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)