akka-stream-kafka_2.11-0.16.jar

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

com.typesafe.akka:akka-stream-kafka_2.11:0.16

<?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.16</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.11</version>

        </dependency>

        <dependency>

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

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

            <version>2.4.18</version>

            <scope>test</scope>

        </dependency>

        <dependency>

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

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

            <version>2.4.18</version>

        </dependency>

        <dependency>

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

            <artifactId>kafka-clients</artifactId>

            <version>0.10.2.1</version>

        </dependency>

        <dependency>

            <groupId>org.scalatest</groupId>

            <artifactId>scalatest_2.11</artifactId>

            <version>3.0.1</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.18</version>

            <scope>test</scope>

        </dependency>

        <dependency>

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

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

            <version>2.4.18</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>

        <dependency>

            <groupId>net.manub</groupId>

            <artifactId>scalatest-embedded-kafka_2.11</artifactId>

            <version>0.13.0</version>

            <scope>test</scope>

            <exclusions>

                <exclusion>

                    <groupId>log4j</groupId>

                    <artifactId>log4j</artifactId>

                </exclusion>

            </exclusions>

        </dependency>

        <dependency>

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

            <artifactId>kafka_2.11</artifactId>

            <version>0.10.2.1</version>

            <scope>test</scope>

            <exclusions>

                <exclusion>

                    <groupId>org.slf4j</groupId>

                    <artifactId>slf4j-log4j12</artifactId>

                </exclusion>

            </exclusions>

        </dependency>

    </dependencies>

</project>

META-INF/MANIFEST.MF
akka.kafka.KafkaConsumerActor$$anonfun$receive$1$$anonfun$applyOrElse$1.class
akka.kafka.Subscriptions$Assignment.class
akka.kafka.scaladsl.Producer$$anonfun$commitableSink$1.class
akka.kafka.internal.ConsumerStage$.class
akka.kafka.internal.SubSourceLogic$$anonfun$2.class
akka.kafka.javadsl.Consumer$$anonfun$plainExternalSource$1.class
akka.kafka.internal.SingleSourceLogic$$anonfun$2.class
akka.kafka.internal.ProducerStage$$anon$1$$anon$2.class
akka.kafka.internal.ProducerStage$$anon$1$$anonfun$1.class
akka.kafka.KafkaConsumerActor$$anonfun$postStop$1.class
akka.kafka.internal.ConsumerStage$$anon$10$$anon$4.class
akka.kafka.internal.SubSourceLogic$$anonfun$performShutdown$1.class
akka.kafka.scaladsl.Consumer$Control.class
akka.kafka.internal.ConsumerStage$$anon$11$$anon$5.class
akka.kafka.javadsl.Consumer$$anonfun$committableSource$1.class
akka.kafka.internal.SingleSourceLogic.class
akka.kafka.Subscriptions$.class
akka.kafka.KafkaConsumerActor$Internal$Messages$.class
akka.kafka.KafkaConsumerActor$$anonfun$checkOverlappingRequests$1.class
akka.kafka.KafkaConsumerActor$$anon$1.class
akka.kafka.KafkaConsumerActor$$anonfun$receive$1$$anonfun$2.class
akka.kafka.internal.ExternalSingleSourceLogic$$anonfun$preStart$1$$anonfun$apply$1.class
akka.kafka.scaladsl.Producer$$anonfun$2.class
akka.kafka.internal.ConsumerStage$PlainMessageBuilder.class
akka.kafka.scaladsl.Producer$$anonfun$plainSink$2.class
akka.kafka.internal.SubSourceLogic$$anonfun$3.class
akka.kafka.Subscriptions$Assignment$.class
akka.kafka.internal.ConsumerStage.class
akka.kafka.internal.SubSourceLogic$SubSourceStage$$anon$1$$anonfun$preStart$2.class
akka.kafka.ConsumerMessage.class
akka.kafka.internal.ConsumerStage$$anon$8.class
akka.kafka.internal.SubSourceLogic$$anonfun$2$$anonfun$apply$2$$anonfun$apply$3.class
akka.kafka.KafkaConsumerActor$$anonfun$1.class
akka.kafka.internal.ProducerStage$$anon$1$$anon$3$$anon$4.class
akka.kafka.internal.SingleSourceLogic$$anonfun$preStart$1.class
akka.kafka.Subscriptions$TopicSubscriptionPattern$.class
akka.kafka.KafkaConsumerActor$.class
akka.kafka.internal.SingleSourceLogic$$anonfun$1.class
akka.kafka.internal.SubSourceLogic$SubSourceStage$$anon$1$$anon$3.class
akka.kafka.scaladsl.Producer.class
akka.kafka.internal.ConfigSettings.class
akka.kafka.internal.ConsumerStage$$anon$11.class
akka.kafka.internal.ControlShutdown$.class
akka.kafka.internal.ConsumerStage$$anon$8$$anon$2.class
akka.kafka.internal.SubSourceLogic$SubSourceStage.class
akka.kafka.KafkaConsumerActor$Internal$.class
akka.kafka.internal.ConsumerStage$$anon$12$$anon$6.class
akka.kafka.internal.ProducerStage.class
akka.kafka.ConsumerMessage$PartitionOffset.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef$$anonfun$2.class
akka.kafka.scaladsl.Producer$.class
akka.kafka.internal.SingleSourceLogic$$anonfun$rebalanceListener$1$2.class
akka.kafka.internal.ControlStop.class
akka.kafka.internal.ConsumerStage$$anon$9.class
akka.kafka.ConsumerMessage$GroupTopicPartition.class
akka.kafka.javadsl.Producer$$anonfun$plainSink$1.class
akka.kafka.javadsl.Consumer$$anonfun$committablePartitionedSource$2.class
akka.kafka.internal.ExternalSingleSourceLogic$$anonfun$1.class
akka.kafka.scaladsl.Producer$$anonfun$plainSink$1.class
akka.kafka.KafkaConsumerActor$$anonfun$poll$1.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedSource$1.class
akka.kafka.internal.ConsumerStage$$anon$12.class
akka.kafka.ProducerSettings$$anonfun$apply$1.class
akka.kafka.ProducerSettings.class
akka.kafka.internal.ConsumerStage$KafkaSourceStage.class
akka.kafka.internal.PromiseControl$$anonfun$preStart$1.class
akka.kafka.internal.PromiseControl.class
akka.kafka.AutoSubscription.class
akka.kafka.ConsumerSettings$$anonfun$apply$1.class
akka.kafka.internal.MessageBuilder.class
akka.kafka.internal.SubSourceLogic.class
akka.kafka.KafkaConsumerActor$$anonfun$processResult$1$$anonfun$4$$anonfun$apply$2.class
akka.kafka.internal.ControlShutdown.class
akka.kafka.internal.SingleSourceLogic$$anonfun$performShutdown$1.class
akka.kafka.KafkaConsumerActor$Internal$SubscribePattern$.class
akka.kafka.ProducerMessage$.class
akka.kafka.ConsumerMessage$Committable.class
akka.kafka.ConsumerMessage$CommittableOffset.class
akka.kafka.KafkaConsumerActor$Internal$Poll.class
akka.kafka.ConsumerMessage$CommittableOffsetBatch.class
akka.kafka.javadsl.Consumer$$anonfun$atMostOnceSource$1.class
akka.kafka.internal.ConsumerStage$CommittableMessageBuilder.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef$$anonfun$3$$anonfun$5.class
akka.kafka.javadsl.Producer$.class
akka.kafka.ConsumerMessage$CommittableOffsetBatch$.class
akka.kafka.internal.ConsumerStage$$anon$7$$anon$1.class
akka.kafka.internal.SubSourceLogic$$anonfun$4.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef.class
akka.kafka.KafkaConsumerActor$Internal$Messages.class
akka.kafka.internal.ConsumerStage$WrappedConsumerControl.class
akka.kafka.KafkaConsumerActor$$anonfun$stopping$1.class
akka.kafka.KafkaConsumerActor$Internal$Stop$.class
akka.kafka.internal.SubSourceLogic$$anonfun$rebalanceListener$1$1.class
akka.kafka.internal.ExternalSingleSourceLogic$$anonfun$2.class
akka.kafka.KafkaConsumerActor$Internal$Assigned$.class
akka.kafka.ConsumerSettings$$anonfun$apply$2.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef$$anonfun$3$$anonfun$4.class
akka.kafka.Subscriptions$TopicSubscription.class
akka.kafka.javadsl.Producer$$anonfun$commitableSink$2.class
akka.kafka.KafkaConsumerActor.class
akka.kafka.internal.ExternalSingleSourceLogic$$anon$1.class
akka.kafka.ConsumerSettings$$anonfun$1.class
akka.kafka.KafkaConsumerActor$$anonfun$processResult$1.class
akka.kafka.internal.ControlStop$.class
akka.kafka.scaladsl.Consumer$$anonfun$atMostOnceSource$1$$anonfun$apply$1.class
akka.kafka.javadsl.Consumer$$anonfun$plainSource$1.class
akka.kafka.ProducerSettings$.class
akka.kafka.internal.ConfigSettings$$anonfun$parseKafkaClientsProperties$1.class
akka.kafka.scaladsl.Consumer.class
akka.kafka.internal.SubSourceLogic$$anonfun$preStart$1.class
akka.kafka.Subscriptions$AssignmentWithOffset.class
akka.kafka.ConsumerSettings$$anonfun$getProperty$1.class
akka.kafka.KafkaConsumerActor$Internal$AssignWithOffset$.class
akka.kafka.internal.PromiseControl$class.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef$$anonfun$commit$1.class
akka.kafka.ConsumerMessage$CommittableMessage.class
akka.kafka.javadsl.Consumer$.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef$$anonfun$3.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef$$anonfun$commit$2.class
akka.kafka.ProducerMessage$Result.class
akka.kafka.KafkaConsumerActor$Internal$Committed.class
akka.kafka.internal.SubSourceLogic$SubSourceStage$$anon$1$$anonfun$preStart$2$$anonfun$apply$4.class
akka.kafka.internal.SubSourceLogic$$anonfun$1.class
akka.kafka.ConsumerMessage$GroupTopicPartition$.class
akka.kafka.ProducerMessage$Message.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedSource$2.class
akka.kafka.internal.ConsumerStage$CommittableOffsetBatchImpl.class
akka.kafka.javadsl.Consumer$$anonfun$committableExternalSource$1.class
akka.kafka.scaladsl.Producer$$anonfun$1.class
akka.kafka.KafkaConsumerActor$Internal$Subscribe.class
akka.kafka.internal.ProducerStage$$anon$1.class
akka.kafka.internal.ConsumerStage$$anon$7.class
akka.kafka.KafkaConsumerActor$Internal$RequestMessages$.class
akka.kafka.KafkaConsumerActor$Internal$Assigned.class
akka.kafka.scaladsl.Producer$$anonfun$4.class
akka.kafka.Subscriptions$AssignmentWithOffset$.class
akka.kafka.scaladsl.Producer$$anonfun$3.class
akka.kafka.ProducerMessage$Result$.class
akka.kafka.internal.SubSourceLogic$$anonfun$performShutdown$2.class
akka.kafka.internal.SingleSourceLogic$$anon$1.class
akka.kafka.internal.ConsumerStage$CommittableOffsetBatchImpl$$anonfun$6.class
akka.kafka.scaladsl.Producer$$anonfun$commitableSink$2.class
akka.kafka.scaladsl.Consumer$.class
akka.kafka.KafkaConsumerActor$Internal$SubscribePattern.class
akka.kafka.ProducerMessage$Message$.class
akka.kafka.KafkaConsumerActor$$anonfun$checkOverlappingRequests$1$$anonfun$apply$1.class
akka.kafka.internal.ConsumerStage$CommittableOffsetImpl$.class
akka.kafka.internal.SingleSourceLogic$$anonfun$preStart$1$$anonfun$apply$1.class
akka.kafka.KafkaConsumerActor$Internal$Revoked$.class
akka.kafka.internal.SubSourceLogic$$anon$2.class
akka.kafka.ConsumerSettings.class
akka.kafka.internal.ConsumerStage$KafkaAsyncConsumerCommitterRef$.class
reference.conf
akka.kafka.internal.ExternalSingleSourceLogic.class
akka.kafka.ProducerSettings$$anonfun$apply$2.class
akka.kafka.KafkaConsumerActor$Internal$Subscribe$.class
akka.kafka.Subscriptions.class
akka.kafka.internal.ConsumerStage$$anon$10.class
akka.kafka.KafkaConsumerActor$Internal$Assign.class
akka.kafka.Subscriptions$TopicSubscription$.class
akka.kafka.internal.ControlOperation.class
akka.kafka.KafkaConsumerActor$$anonfun$receive$1.class
akka.kafka.internal.SingleSourceLogic$$anonfun$rebalanceListener$1$1.class
akka.kafka.KafkaConsumerActor$$anonfun$3.class
akka.kafka.ConsumerMessage$CommittableMessage$.class
akka.kafka.javadsl.Consumer$$anonfun$committablePartitionedSource$1.class
akka.kafka.KafkaConsumerActor$$anonfun$receive$1$$anon$2.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)