| 组织ID: |
com.typesafe.akka |
| 项目ID: |
akka-stream-kafka_2.12 |
| 版本: |
1.0.1 |
| 最后修改时间: |
2019-03-08 17:09:13 |
| 包类型: |
jar |
| 标题: |
Apache-2.0 |
| 描述: |
akka-stream-kafka |
| 相关URL: |
https://doc.akka.io/docs/alpakka-kafka/current/ |
| 大小: |
473.40KB |
|
|
| Maven引入代码: |
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-stream-kafka_2.12</artifactId>
<version>1.0.1</version>
</dependency>
|
| Gradle引入代码: |
com.typesafe.akka:akka-stream-kafka_2.12:1.0.1
|
| 下载Jar包: |
|
| POM文件内容: |
<?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.12</artifactId>
<packaging>jar</packaging>
<description>akka-stream-kafka</description>
<url>https://doc.akka.io/docs/alpakka-kafka/current/</url>
<version>1.0.1</version>
<licenses>
<license>
<name>Apache-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 Inc.</name>
<url>https://doc.akka.io/docs/alpakka-kafka/current/</url>
</organization>
<scm>
<url>https://github.com/akka/alpakka-kafka</url>
<connection>git@github.com:akka/alpakka-kafka.git</connection>
</scm>
<developers>
<developer>
<id>contributors</id>
<name>Contributors</name>
<email>https://gitter.im/akka/dev</email>
<url>https://github.com/akka/alpakka-kafka/graphs/contributors</url>
</developer>
</developers>
<dependencies>
<dependency>
<groupId>org.scala-lang</groupId>
<artifactId>scala-library</artifactId>
<version>2.12.8</version>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-stream_2.12</artifactId>
<version>2.5.21</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.1.1</version>
</dependency>
</dependencies>
<repositories>
<repository>
<id>bintraymanubmaven</id>
<name>bintray-manub-maven</name>
<url>https://dl.bintray.com/manub/maven/</url>
<layout>default</layout>
</repository>
<repository>
<id>bintrayakkamaven</id>
<name>bintray-akka-maven</name>
<url>https://dl.bintray.com/akka/maven/</url>
<layout>default</layout>
</repository>
</repositories>
</project>
|
| Jar包内容: |
META-INF/MANIFEST.MF
akka.kafka.internal.ConfigSettings.class
akka.kafka.ConsumerSettings$.class
akka.kafka.ProducerMessage$Message.class
akka.kafka.Metadata$GetOffsetsForTimes.class
akka.kafka.ConsumerMessage$PartitionOffsetMetadata.class
akka.kafka.internal.SubSourceLogic$$anonfun$seekAndEmitSubSources$2.class
akka.kafka.ProducerMessage$Message$.class
akka.kafka.Subscriptions$AssignmentOffsetsForTimes$.class
akka.kafka.javadsl.Consumer$Control.class
akka.kafka.internal.TransactionalSource.class
akka.kafka.internal.TransactionalProducerStage$NonemptyTransactionBatch$.class
akka.kafka.ProducerMessage.class
akka.kafka.internal.KafkaConsumerActor$Internal$Poll$.class
akka.kafka.internal.MetricsControl.class
akka.kafka.internal.MessageBuilder.class
akka.kafka.scaladsl.Transactional$.class
akka.kafka.ProducerMessage$PassThroughResult.class
akka.kafka.internal.KafkaConsumerActor$Internal$Committed.class
akka.kafka.ProducerMessage$MultiResultPart.class
akka.kafka.internal.KafkaConsumerActor$ListenerCallbacks$.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$.class
akka.kafka.scaladsl.Consumer$DrainingControl$.class
akka.kafka.internal.DefaultProducerStageLogic$$anon$3.class
akka.kafka.internal.InternalCommitter.class
akka.kafka.Metadata$BeginningOffsets.class
akka.kafka.Metadata$GetOffsetsForTimes$.class
akka.kafka.ProducerMessage$Result$.class
akka.kafka.scaladsl.Committer.class
akka.kafka.internal.KafkaConsumerActor$Internal$AssignWithOffset.class
akka.kafka.internal.CommittableOffsetImpl$.class
akka.kafka.internal.ProducerStage$.class
akka.kafka.internal.KafkaConsumerActor$Internal$SubscribePattern$.class
akka.kafka.ConsumerFailed.class
akka.kafka.internal.ExternalPlainSource$$anon$2.class
akka.kafka.InitialPollFailed.class
akka.kafka.internal.SingleSourceLogic.class
akka.kafka.internal.SubSourceLogic$$anon$2.class
akka.kafka.ConsumerMessage$PartitionOffsetMetadata$.class
reference.conf
akka.kafka.scaladsl.Consumer.class
akka.kafka.ProducerMessage$MultiResult$.class
akka.kafka.ConsumerMessage$CommittableOffsetBatch$.class
akka.kafka.internal.TransactionalProducerStageLogic.class
akka.kafka.internal.CommittableSubSource$$anon$3.class
akka.kafka.scaladsl.Committer$.class
akka.kafka.javadsl.Consumer$.class
akka.kafka.internal.TransactionalProducerStage.class
akka.kafka.javadsl.Committer.class
akka.kafka.javadsl.Committer$.class
akka.kafka.CommitterSettings.class
akka.kafka.internal.TransactionalProducerStage$NonemptyTransactionBatch.class
akka.kafka.javadsl.Consumer.class
akka.kafka.ConsumerMessage$CommittableMessage.class
akka.kafka.scaladsl.Producer$.class
akka.kafka.Metadata$ListTopics$.class
akka.kafka.TopicPartitionsRevoked.class
akka.kafka.internal.KafkaConsumerActor$Internal$SubscriptionRequest.class
akka.kafka.Subscriptions$AssignmentOffsetsForTimes.class
akka.kafka.javadsl.Producer.class
akka.kafka.scaladsl.Producer.class
akka.kafka.internal.SubSourceLogic$.class
akka.kafka.internal.CommittableSubSource.class
akka.kafka.ConsumerMessage$GroupTopicPartition.class
akka.kafka.internal.KafkaConsumerActor$Internal$Assign.class
akka.kafka.internal.KafkaConsumerActor$Internal$Subscribe.class
akka.kafka.internal.ProducerStage$ProducerCompletionState.class
akka.kafka.internal.SubSourceLogic$$anon$1.class
akka.kafka.Metadata.class
akka.kafka.internal.ConsumerControlAsJava.class
akka.kafka.Metadata$GetPartitionsFor$.class
akka.kafka.ProducerMessage$Results.class
akka.kafka.internal.TransactionalMessageBuilder.class
akka.kafka.internal.TransactionalProducerStage$TransactionBatch$.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef.class
akka.kafka.KafkaConsumerActor$.class
akka.kafka.internal.KafkaConsumerActor$.class
akka.kafka.Metadata$GetBeginningOffsets.class
akka.kafka.internal.PlainMessageBuilder.class
akka.kafka.internal.KafkaConsumerActor$Internal$Assigned$.class
akka.kafka.internal.KafkaConsumerActor$Internal$AssignOffsetsForTimes.class
akka.kafka.internal.CommittableSubSource$.class
akka.kafka.Metadata$Topics.class
akka.kafka.internal.KafkaConsumerActor$Internal$PartitionRevoked$.class
akka.kafka.internal.KafkaConsumerActor$Internal$AssignOffsetsForTimes$.class
akka.kafka.internal.KafkaConsumerActor$Internal$PollTask$.class
akka.kafka.internal.ProducerStage$MessageCallback.class
akka.kafka.Metadata$.class
akka.kafka.internal.BaseSingleSourceLogic.class
akka.kafka.ProducerSettings.class
akka.kafka.KafkaConsumerActor$Stop$.class
akka.kafka.internal.KafkaConsumerActor$Internal$Assigned.class
akka.kafka.Metadata$PartitionsFor$.class
akka.kafka.ProducerSettings$.class
akka.kafka.internal.KafkaConsumerActor$Internal$Commit.class
akka.kafka.javadsl.Producer$.class
akka.kafka.Metadata$BeginningOffsets$.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$Committed$.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$2.class
akka.kafka.CommitterSettings$.class
akka.kafka.internal.KafkaConsumerActor$Internal$Subscribe$.class
akka.kafka.internal.ProducerStage.class
akka.kafka.ConsumerMessage$CommittableOffsetBatch.class
akka.kafka.Subscriptions$TopicSubscription$.class
akka.kafka.internal.KafkaConsumerActor.class
akka.kafka.internal.CommittableSource$$anon$1.class
akka.kafka.ConsumerSettings.class
akka.kafka.ManualSubscription.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$commit$3.class
akka.kafka.scaladsl.Transactional.class
akka.kafka.Metadata$EndOffsets.class
akka.kafka.ConsumerMessage$PartitionOffset$.class
akka.kafka.internal.CommittableMessageBuilder.class
akka.kafka.ProducerMessage$Result.class
akka.kafka.internal.DefaultProducerStageLogic$$anon$1.class
akka.kafka.KafkaConsumerActor$StoppingException$.class
akka.kafka.internal.PromiseControl$ControlStop$.class
akka.kafka.internal.KafkaConsumerActor$Internal$Revoked$.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$2$$anonfun$applyOrElse$2.class
akka.kafka.javadsl.Transactional.class
akka.kafka.internal.KafkaConsumerActor$WrappedAutoPausedListener.class
akka.kafka.ConsumerMessage$CommittableOffsetMetadata.class
akka.kafka.internal.PromiseControl$ControlOperation.class
akka.kafka.internal.TransactionalProducerStage$TransactionBatch.class
akka.kafka.ConsumerSettings$$anonfun$$lessinit$greater$1.class
akka.kafka.internal.PromiseControl$ControlShutdown$.class
akka.kafka.internal.KafkaConsumerActor$Internal$Commit$.class
akka.kafka.ProducerMessage$.class
akka.kafka.internal.SubSourceStage.class
akka.kafka.internal.KafkaConsumerActor$Internal$Messages$.class
akka.kafka.internal.KafkaConsumerActor$Internal$ConsumerMetrics$.class
akka.kafka.ConsumerMessage$CommittableOffset.class
akka.kafka.internal.SubSourceLogic.class
akka.kafka.Metadata$GetPartitionsFor.class
akka.kafka.Subscriptions$Assignment$.class
akka.kafka.Subscriptions.class
akka.kafka.internal.ConfigSettings$.class
akka.kafka.internal.ExternalCommittableSource$$anon$2.class
akka.kafka.ConsumerMessage$.class
akka.kafka.internal.TransactionalProducerStage$EmptyTransactionBatch.class
akka.kafka.scaladsl.Consumer$DrainingControl.class
akka.kafka.ProducerMessage$MultiMessage$.class
akka.kafka.internal.PlainSource$$anon$1.class
akka.kafka.ProducerMessage$MultiResultPart$.class
akka.kafka.internal.SubSourceStage$$anon$3.class
akka.kafka.internal.TransactionalProducerStage$.class
akka.kafka.internal.KafkaConsumerActor$$anon$1.class
akka.kafka.internal.CommittableOffsetBatchImpl.class
akka.kafka.internal.KafkaConsumerActor$Internal$RequestMessages.class
akka.kafka.Metadata$EndOffsets$.class
akka.kafka.Metadata$Request.class
akka.kafka.Metadata$GetBeginningOffsets$.class
akka.kafka.Metadata$GetCommittedOffset$.class
akka.kafka.internal.TransactionalProducerStageLogic$$anon$1.class
akka.kafka.ProducerMessage$MultiMessage.class
akka.kafka.internal.CommittableSource$.class
akka.kafka.internal.SubSourceStage$$anon$3$$anon$4.class
akka.kafka.ProducerMessage$PassThroughResult$.class
akka.kafka.ConsumerMessage$CommittableMessage$.class
akka.kafka.ProducerMessage$Envelope.class
akka.kafka.internal.ExternalPlainSource.class
akka.kafka.AutoSubscription.class
akka.kafka.internal.ConsumerControlAsJava$.class
akka.kafka.Subscriptions$TopicSubscriptionPattern$.class
akka.kafka.internal.KafkaConsumerActor$Internal$PartitionAssigned$.class
akka.kafka.ConsumerRebalanceEvent.class
akka.kafka.internal.CommittableSource.class
akka.kafka.internal.TransactionalSource$$anon$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$AssignWithOffset$.class
akka.kafka.internal.KafkaConsumerActor$ListenerCallbacks.class
akka.kafka.internal.KafkaConsumerActor$Internal$SubscribePattern.class
akka.kafka.Subscription.class
akka.kafka.Subscriptions$TopicSubscription.class
akka.kafka.CommitTimeoutException.class
akka.kafka.ConsumerMessage$PartitionOffset.class
akka.kafka.KafkaConsumerActor$StoppingException.class
akka.kafka.internal.BaseSingleSourceLogic$$anon$1.class
akka.kafka.Subscriptions$TopicSubscriptionPattern.class
akka.kafka.internal.KafkaConsumerActor$Internal$PartitionAssigned.class
akka.kafka.internal.CommittableOffsetImpl.class
akka.kafka.internal.PlainSource.class
akka.kafka.Subscriptions$Assignment.class
akka.kafka.ConsumerMessage$TransactionalMessage$.class
akka.kafka.internal.PromiseControl.class
akka.kafka.TopicPartitionsAssigned.class
akka.kafka.Metadata$Response.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$stopping$1.class
akka.kafka.Subscriptions$AssignmentWithOffset$.class
akka.kafka.internal.DefaultProducerStage.class
akka.kafka.ProducerMessage$MultiResult.class
akka.kafka.internal.KafkaConsumerActor$Internal$Assign$.class
akka.kafka.internal.ExternalSingleSourceLogic.class
akka.kafka.internal.DefaultProducerStageLogic$$anon$2.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)
|
| 依赖Jar: |
scala-library-2.12.8.jar
/org.scala-lang/scala-library/2.12.8
查看scala-library所有版本文件
akka-stream_2.12-2.5.21.jar
/com.typesafe.akka/akka-stream_2.12/2.5.21
查看akka-stream_2.12所有版本文件
kafka-clients-2.1.1.jar
/org.apache.kafka/kafka-clients/2.1.1
查看kafka-clients所有版本文件
|
查看akka-stream-kafka_2.12所有版本文件