| 组织ID: |
com.typesafe.akka |
| 项目ID: |
akka-stream-kafka_2.11 |
| 版本: |
1.0-RC2 |
| 最后修改时间: |
2019-12-04 11:41:42 |
| 包类型: |
jar |
| 标题: |
Apache-2.0 |
| 描述: |
akka-stream-kafka |
| 相关URL: |
https://doc.akka.io/docs/alpakka-kafka/current/ |
| 大小: |
631.42KB |
|
|
| Maven引入代码: |
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-stream-kafka_2.11</artifactId>
<version>1.0-RC2</version>
</dependency>
|
| Gradle引入代码: |
com.typesafe.akka:akka-stream-kafka_2.11:1.0-RC2
|
| 下载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.11</artifactId>
<packaging>jar</packaging>
<description>akka-stream-kafka</description>
<url>https://doc.akka.io/docs/alpakka-kafka/current/</url>
<version>1.0-RC2</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.11.12</version>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-stream_2.11</artifactId>
<version>2.5.21</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.1.0</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.KafkaConsumerActor$Internal$SubscriptionRequest.class
akka.kafka.internal.InternalCommitter.class
akka.kafka.Metadata$EndOffsets$$anonfun$getResponse$7.class
akka.kafka.Subscriptions$TopicSubscriptionPattern$.class
akka.kafka.ConsumerRebalanceEvent.class
akka.kafka.internal.TransactionalSource.class
akka.kafka.ProducerSettings$$anonfun$$lessinit$greater$1.class
akka.kafka.javadsl.Committer$$anonfun$sink$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$Poll.class
akka.kafka.javadsl.Committer.class
akka.kafka.internal.SubSourceLogic$$anonfun$performShutdown$2.class
akka.kafka.ConsumerMessage$CommittableMessage$.class
akka.kafka.internal.SubSourceStage.class
akka.kafka.Metadata$PartitionsFor.class
akka.kafka.internal.KafkaConsumerActor$Internal$Poll$.class
akka.kafka.Metadata$PartitionsFor$$anonfun$getResponse$4.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$commit$3.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$1.class
akka.kafka.ProducerSettings$$anonfun$apply$1.class
akka.kafka.internal.ConsumerControlAsJava.class
akka.kafka.internal.KafkaConsumerActor$Internal$PartitionAssigned.class
akka.kafka.scaladsl.Consumer$NoopControl$.class
akka.kafka.Metadata$BeginningOffsets.class
akka.kafka.internal.KafkaConsumerActor$Internal$Committed$.class
akka.kafka.internal.KafkaConsumerActor$Internal$ConsumerMetrics$.class
akka.kafka.ConsumerMessage$CommittableOffsetBatch.class
akka.kafka.Subscriptions$TopicSubscriptionPattern.class
akka.kafka.internal.SingleSourceLogic$$anonfun$rebalanceListener$1$2.class
reference.conf
akka.kafka.ProducerMessage$PassThroughMessage.class
akka.kafka.scaladsl.Consumer$$anonfun$atMostOnceSource$1$$anonfun$apply$3.class
akka.kafka.internal.SubSourceLogic$$anonfun$3$$anonfun$apply$3.class
akka.kafka.internal.KafkaConsumerActor$Internal$Revoked.class
akka.kafka.javadsl.Consumer$$anonfun$commitWithMetadataSource$1.class
akka.kafka.ProducerSettings$$anonfun$apply$2.class
akka.kafka.Metadata$.class
akka.kafka.Subscriptions$Assignment$.class
akka.kafka.internal.PromiseControl.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$3$$anonfun$apply$1.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$2.class
akka.kafka.internal.KafkaConsumerActor$Internal$Subscribe.class
akka.kafka.Metadata$Topics$.class
akka.kafka.internal.PlainMessageBuilder$class.class
akka.kafka.internal.KafkaConsumerActor$WrappedAutoPausedListener$$anonfun$1.class
akka.kafka.scaladsl.Transactional$$anonfun$1.class
akka.kafka.javadsl.Consumer$$anonfun$commitWithMetadataPartitionedSource$3.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$3$$anonfun$4.class
akka.kafka.Metadata$ListTopics$.class
akka.kafka.ProducerMessage$PassThroughMessage$.class
akka.kafka.internal.KafkaConsumerActor$Internal$Committed.class
akka.kafka.internal.DefaultProducerStageLogic$$anon$2.class
akka.kafka.internal.PlainSubSource$$anon$3.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$3$$anonfun$apply$6.class
akka.kafka.internal.KafkaSourceStage.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$applyOrElse$1.class
akka.kafka.Metadata$BeginningOffsets$.class
akka.kafka.internal.ExternalPlainSource$$anon$2.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$4$$anonfun$apply$7.class
akka.kafka.scaladsl.Producer$$anonfun$4.class
akka.kafka.internal.CommittableOffsetBatchImpl$$anonfun$offsets$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$processResult$1$$anonfun$10$$anonfun$apply$4.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$applyOrElse$3.class
akka.kafka.internal.DefaultProducerStageLogic$$anonfun$2.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$1$$anonfun$apply$1.class
akka.kafka.internal.TransactionalProducerStage.class
akka.kafka.ManualSubscription$class.class
akka.kafka.javadsl.Consumer.class
akka.kafka.internal.TransactionalProducerStageLogic.class
akka.kafka.internal.KafkaConsumerActor$Internal$Messages$.class
akka.kafka.ConsumerMessage$.class
akka.kafka.javadsl.Consumer$$anonfun$committablePartitionedSource$1.class
akka.kafka.Subscriptions$AssignmentWithOffset$$anonfun$renderStageAttribute$1.class
akka.kafka.internal.DefaultProducerStageLogic$$anonfun$akka$kafka$internal$DefaultProducerStageLogic$$decider$1.class
akka.kafka.scaladsl.Producer$$anonfun$5.class
akka.kafka.scaladsl.Consumer$Control.class
akka.kafka.scaladsl.Committer$$anonfun$flow$3.class
akka.kafka.internal.KafkaConsumerActor$Internal$Assigned.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$applyOrElse$4$$anonfun$apply$2.class
akka.kafka.scaladsl.Consumer$Control$class.class
akka.kafka.internal.SubSourceLogic$$anonfun$5.class
akka.kafka.scaladsl.Committer$$anonfun$flow$2.class
akka.kafka.internal.SubSourceLogic$$anon$2.class
akka.kafka.internal.MetricsControl$$anonfun$metrics$1$$anonfun$apply$1.class
akka.kafka.Metadata$PartitionsFor$$anonfun$getResponse$3.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$6.class
akka.kafka.internal.PromiseControl$.class
akka.kafka.ProducerMessage$Message.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$3$$anonfun$apply$2.class
akka.kafka.internal.SingleSourceLogic$$anonfun$rebalanceListener$1$1.class
akka.kafka.internal.CommittableSource$.class
akka.kafka.internal.SingleSourceLogic.class
akka.kafka.internal.SingleSourceLogic$$anonfun$rebalanceListener$1$2$$anonfun$apply$2.class
akka.kafka.Metadata$EndOffsets$$anonfun$getResponse$7$$anonfun$apply$3.class
akka.kafka.internal.KafkaConsumerActor$Internal$Seek$.class
akka.kafka.scaladsl.Producer$$anonfun$2.class
akka.kafka.Metadata$Topics.class
akka.kafka.internal.PlainMessageBuilder.class
akka.kafka.ConsumerMessage$PartitionOffsetMetadata$.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$3.class
akka.kafka.internal.KafkaConsumerActor$Internal$Commit.class
akka.kafka.CommitTimeoutException.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$applyOrElse$4.class
akka.kafka.internal.PlainSource$$anon$1.class
akka.kafka.ProducerMessage$MultiMessage$.class
akka.kafka.internal.ConsumerControlAsJava$.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$preStart$1.class
akka.kafka.internal.PromiseControl$ControlShutdown$.class
akka.kafka.Metadata$GetOffsetsForTimes$.class
akka.kafka.internal.CommittableSubSource$$anonfun$$lessinit$greater$default$3$2.class
akka.kafka.internal.KafkaConsumerActor$Internal$SubscribePattern$.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$7.class
akka.kafka.ConsumerMessage$GroupTopicPartition$.class
akka.kafka.internal.SubSourceStage$$anon$1$$anonfun$preStart$2$$anonfun$apply$4.class
akka.kafka.internal.KafkaConsumerActor$Internal$Commit$.class
akka.kafka.internal.TransactionalProducerStage$.class
akka.kafka.javadsl.Transactional$.class
akka.kafka.internal.KafkaConsumerActor$WrappedAutoPausedListener.class
akka.kafka.scaladsl.Consumer$DrainingControl$.class
akka.kafka.Metadata$GetEndOffsets$.class
akka.kafka.Metadata$EndOffsets$$anonfun$getResponse$8.class
akka.kafka.internal.CommittableOffsetBatchImpl$$anonfun$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$Assigned$.class
akka.kafka.KafkaConsumerActor$StoppingException$.class
akka.kafka.javadsl.Consumer$$anonfun$commitWithMetadataPartitionedSource$1.class
akka.kafka.internal.TransactionalProducerStage$NonemptyTransactionBatch$.class
akka.kafka.Subscriptions$TopicSubscription.class
akka.kafka.javadsl.Producer$$anonfun$plainSink$1.class
akka.kafka.scaladsl.Consumer$$anonfun$plainPartitionedSource$1.class
akka.kafka.scaladsl.Committer.class
akka.kafka.javadsl.Consumer$$anonfun$commitWithMetadataSource$2.class
akka.kafka.CommitterSettings.class
akka.kafka.internal.SubSourceLogic$$anonfun$onTimer$1.class
akka.kafka.Metadata$Request.class
akka.kafka.scaladsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$default$4$1.class
akka.kafka.internal.ProducerStage$MessageCallback.class
akka.kafka.scaladsl.Transactional$$anonfun$flow$1.class
akka.kafka.ProducerMessage$Results.class
akka.kafka.ManualSubscription.class
akka.kafka.internal.PromiseControl$class.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$commit$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$5.class
akka.kafka.internal.TransactionalProducerStage$NonemptyTransactionBatch$$anonfun$offsetMap$1.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$1$$anonfun$applyOrElse$2.class
akka.kafka.ConsumerMessage$CommittableOffset.class
akka.kafka.internal.SubSourceLogic$$anonfun$akka$kafka$internal$SubSourceLogic$$seekAndEmitSubSources$1.class
akka.kafka.internal.BaseSingleSourceLogic.class
akka.kafka.javadsl.Producer$.class
akka.kafka.internal.DefaultProducerStageLogic$$anonfun$4$$anonfun$apply$1.class
akka.kafka.internal.DefaultProducerStageLogic$$anonfun$1.class
akka.kafka.javadsl.Transactional$$anonfun$sink$1.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$.class
akka.kafka.Metadata$OffsetsForTimes$.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$1.class
akka.kafka.CommitterSettings$.class
akka.kafka.ProducerMessage$MultiResult$.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$2.class
akka.kafka.Metadata$BeginningOffsets$$anonfun$getResponse$5.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$postStop$1.class
akka.kafka.internal.MetricsControl$$anonfun$metrics$1.class
akka.kafka.internal.SubSourceLogic$$anonfun$rebalanceListener$1$2.class
akka.kafka.internal.DefaultProducerStageLogic$$anonfun$5.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$checkOverlappingRequests$1$$anonfun$apply$3.class
akka.kafka.internal.DefaultProducerStageLogic$$anonfun$akka$kafka$internal$DefaultProducerStageLogic$$decider$2.class
akka.kafka.internal.KafkaConsumerActor$$anon$1.class
akka.kafka.internal.SingleSourceLogic$$anonfun$2.class
akka.kafka.internal.CommittableSource$$anon$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$5$$anonfun$11.class
akka.kafka.javadsl.Consumer$Control.class
akka.kafka.ProducerSettings$.class
akka.kafka.Metadata$GetBeginningOffsets$.class
akka.kafka.scaladsl.Transactional.class
akka.kafka.Metadata$OffsetsForTimes.class
akka.kafka.Metadata$Topics$$anonfun$getResponse$1.class
akka.kafka.internal.SubSourceLogic$$anonfun$performShutdown$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$4.class
akka.kafka.TopicPartitionsRevoked.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$6.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$8.class
akka.kafka.ProducerMessage$PassThroughResult.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$checkOverlappingRequests$1.class
akka.kafka.scaladsl.Producer$$anonfun$6.class
akka.kafka.Metadata$OffsetsForTimes$$anonfun$getResponse$10.class
akka.kafka.internal.SubSourceLogic$$anonfun$akka$kafka$internal$SubSourceLogic$$updatePendingPartitionsAndEmitSubSources$1.class
akka.kafka.ProducerMessage$MultiMessage.class
akka.kafka.Metadata$GetEndOffsets.class
akka.kafka.Subscriptions$AssignmentOffsetsForTimes$.class
akka.kafka.javadsl.Consumer$$anonfun$atMostOnceSource$1.class
akka.kafka.ConsumerFailed.class
akka.kafka.internal.SubSourceLogic$$anonfun$1.class
akka.kafka.internal.DefaultProducerStageLogic$$anon$3.class
akka.kafka.internal.ExternalPlainSource.class
akka.kafka.internal.ExternalCommittableSource$$anon$2.class
akka.kafka.Metadata$PartitionsFor$.class
akka.kafka.javadsl.Consumer$$anonfun$committableExternalSource$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$applyOrElse$3$$anonfun$apply$1.class
akka.kafka.internal.CommittableMessageBuilder.class
akka.kafka.internal.KafkaConsumerActor$Internal$AssignOffsetsForTimes$.class
akka.kafka.internal.SubSourceLogic$$anonfun$rebalanceListener$1$2$$anonfun$apply$2.class
akka.kafka.scaladsl.Consumer$DrainingControl.class
akka.kafka.Subscriptions$AssignmentOffsetsForTimes$$anonfun$renderStageAttribute$2.class
akka.kafka.internal.PromiseControl$$anonfun$1.class
akka.kafka.internal.SingleSourceLogic$$anonfun$1.class
akka.kafka.Metadata$Topics$$anonfun$getResponse$2.class
akka.kafka.internal.TransactionalSource$$anonfun$1.class
akka.kafka.Subscriptions$Assignment.class
akka.kafka.KafkaConsumerActor$$anonfun$props$2.class
akka.kafka.internal.SubSourceLogic$$anonfun$3.class
akka.kafka.internal.SubSourceLogic$$anonfun$preStart$1.class
akka.kafka.internal.MetricsControl$class.class
akka.kafka.internal.BaseSingleSourceLogic$$anonfun$preStart$1$$anonfun$apply$1.class
akka.kafka.scaladsl.Producer$$anonfun$plainSink$2.class
akka.kafka.internal.CommittableOffsetBatchImpl.class
akka.kafka.scaladsl.Producer$$anonfun$7.class
akka.kafka.javadsl.Consumer$$anonfun$commitWithMetadataPartitionedSource$2.class
akka.kafka.Metadata$GetOffsetsForTimes.class
akka.kafka.internal.PlainSource.class
akka.kafka.ConsumerSettings$$anonfun$apply$2.class
akka.kafka.scaladsl.Consumer.class
akka.kafka.internal.KafkaConsumerActor$Internal$AssignWithOffset.class
akka.kafka.internal.SubSourceLogic$$anonfun$akka$kafka$internal$SubSourceLogic$$seekAndEmitSubSources$2.class
akka.kafka.internal.ProducerStage$ProducerCompletionState.class
akka.kafka.ConsumerMessage$CommittableOffsetMetadata.class
akka.kafka.internal.TransactionalSource$$anon$1.class
akka.kafka.scaladsl.Producer$$anonfun$committableSink$2.class
akka.kafka.javadsl.Consumer$$anonfun$committableSource$1.class
akka.kafka.internal.SubSourceStage$$anon$1$$anon$4.class
akka.kafka.internal.MetricsControl.class
akka.kafka.internal.SingleSourceLogic$$anonfun$rebalanceListener$1$1$$anonfun$apply$1.class
akka.kafka.scaladsl.Producer$$anonfun$3.class
akka.kafka.internal.DefaultProducerStage.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$5.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$7.class
akka.kafka.internal.TransactionalMessageBuilder.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$3$$anonfun$5.class
akka.kafka.Metadata$GetCommittedOffset$.class
akka.kafka.KafkaConsumerActor$$anonfun$props$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$5.class
akka.kafka.javadsl.Producer$$anonfun$committableSink$2.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedSource$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$updateCommitRefreshDeadlines$1.class
akka.kafka.ConsumerMessage$CommittableOffsetBatch$$anonfun$apply$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1.class
akka.kafka.internal.SubSourceLogic.class
akka.kafka.scaladsl.Committer$.class
akka.kafka.internal.PlainSubSource.class
akka.kafka.internal.KafkaConsumerActor$.class
akka.kafka.Metadata$GetPartitionsFor.class
akka.kafka.ConsumerSettings$$anonfun$getProperty$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$ConsumerMetrics.class
akka.kafka.ProducerSettings$$anonfun$apply$3.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$4.class
akka.kafka.internal.KafkaConsumerActor$Internal$SubscribePattern.class
akka.kafka.javadsl.Transactional$$anonfun$source$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$Revoked$.class
akka.kafka.ConsumerSettings.class
akka.kafka.internal.TransactionalProducerStageLogic$$anonfun$1.class
akka.kafka.scaladsl.Transactional$.class
akka.kafka.javadsl.Consumer$$anonfun$plainSource$1.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedSource$2.class
akka.kafka.Subscription.class
akka.kafka.javadsl.Consumer$.class
akka.kafka.scaladsl.Producer.class
akka.kafka.internal.TransactionalProducerStage$NonemptyTransactionBatch.class
akka.kafka.Metadata$BeginningOffsets$$anonfun$getResponse$6.class
akka.kafka.ProducerMessage$MultiResultPart.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$1$$anonfun$applyOrElse$1.class
akka.kafka.internal.ExternalSingleSourceLogic.class
akka.kafka.WakeupsExceeded.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$4.class
akka.kafka.internal.SubSourceLogic$$anonfun$4.class
akka.kafka.internal.SubSourceLogic$CloseRevokedPartitions$.class
akka.kafka.ProducerSettings.class
akka.kafka.internal.CommittableOffsetImpl.class
akka.kafka.internal.SubSourceLogic$$anonfun$$lessinit$greater$default$5$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$1$$anonfun$apply$5.class
akka.kafka.internal.KafkaConsumerActor$Internal$Messages.class
akka.kafka.scaladsl.Transactional$$anonfun$2.class
akka.kafka.javadsl.Committer$.class
akka.kafka.Metadata$GetBeginningOffsets.class
akka.kafka.Metadata$Topics$$anonfun$getResponse$1$$anonfun$apply$1.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$9.class
akka.kafka.javadsl.Consumer$DrainingControl.class
akka.kafka.Subscriptions$AssignmentOffsetsForTimes.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$6.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef.class
akka.kafka.Metadata$EndOffsets.class
akka.kafka.ConsumerMessage$PartitionOffsetMetadata.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$receive$1$$anonfun$2.class
akka.kafka.internal.KafkaConsumerActor$$anonfun$akka$kafka$internal$KafkaConsumerActor$$handleMetadataRequest$2.class
akka.kafka.internal.TransactionalProducerStageLogic$$anon$2.class
akka.kafka.Metadata$$anonfun$createGetOffsetForTimes$1.class
akka.kafka.Metadata$EndOffsets$.class
akka.kafka.ProducerMessage$Result.class
akka.kafka.KafkaConsumerActor$.class
akka.kafka.internal.SubSourceLogic$$anon$3.class
akka.kafka.internal.CommittableSource.class
akka.kafka.internal.CommittableOffsetBatchImpl$$anonfun$2.class
akka.kafka.internal.ConsumerControlAsJava$$anonfun$getMetrics$1.class
akka.kafka.javadsl.Transactional.class
akka.kafka.internal.KafkaAsyncConsumerCommitterRef$$anonfun$3.class
akka.kafka.internal.ProducerStage$.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$5$$anonfun$apply$2.class
akka.kafka.internal.TransactionalProducerStageLogic$$anon$1.class
akka.kafka.scaladsl.Producer$.class
akka.kafka.internal.CommittableSource$$anonfun$$lessinit$greater$default$3$1.class
akka.kafka.internal.CommittableOffsetBatchImpl$$anonfun$2$$anonfun$apply$1.class
akka.kafka.KafkaConsumerActor.class
akka.kafka.scaladsl.Producer$$anonfun$committableSink$1.class
akka.kafka.ConsumerMessage$TransactionalMessage$.class
akka.kafka.internal.KafkaConsumerActor$Internal$RequestMetrics$.class
akka.kafka.ProducerMessage.class
akka.kafka.Subscriptions$TopicSubscription$.class
akka.kafka.internal.DefaultProducerStageLogic$$anonfun$4.class
akka.kafka.internal.ConfigSettings$.class
akka.kafka.Subscriptions.class
akka.kafka.KafkaConsumerActor$StoppingException.class
akka.kafka.internal.CommittableMessageBuilder$class.class
akka.kafka.ProducerMessage$MultiResultPart$.class
akka.kafka.internal.SingleSourceLogic$$anonfun$performShutdown$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$Seek.class
akka.kafka.Metadata$CommittedOffset.class
akka.kafka.ConsumerMessage.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$2.class
akka.kafka.javadsl.Consumer$$anonfun$committablePartitionedSource$2.class
akka.kafka.internal.CommittableSubSource.class
akka.kafka.internal.ConfigSettings$$anonfun$parseKafkaClientsProperties$1.class
akka.kafka.javadsl.Consumer$$anonfun$plainPartitionedManualOffsetSource$3.class
akka.kafka.internal.DefaultProducerStageLogic.class
akka.kafka.javadsl.Producer$$anonfun$plainSink$2.class
akka.kafka.javadsl.Producer.class
akka.kafka.scaladsl.Producer$$anonfun$1.class
akka.kafka.internal.KafkaConsumerActor$Internal$PartitionRevoked$.class
akka.kafka.javadsl.Producer$$anonfun$committableSink$1.class
akka.kafka.Metadata$GetCommittedOffset.class
akka.kafka.internal.SingleSourceLogic$$anon$1.class
akka.kafka.internal.SubSourceLogic$$anonfun$rebalanceListener$1$1$$anonfun$apply$1.class
akka.kafka.scaladsl.Consumer$Control$$anonfun$drainAndShutdown$1.class
akka.kafka.TopicPartitionsRevoked$.class
akka.kafka.internal.KafkaConsumerActor$ListenerCallbacks.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)
|
| 依赖Jar: |
scala-library-2.11.12.jar
/org.scala-lang/scala-library/2.11.12
查看scala-library所有版本文件
akka-stream_2.11-2.5.21.jar
/com.typesafe.akka/akka-stream_2.11/2.5.21
查看akka-stream_2.11所有版本文件
kafka-clients-2.1.0.jar
/org.apache.kafka/kafka-clients/2.1.0
查看kafka-clients所有版本文件
|
查看akka-stream-kafka_2.11所有版本文件