reactor-kafka-1.2.0.RELEASE.jar

<dependency>
	<groupId>io.projectreactor.kafka</groupId>
	<artifactId>reactor-kafka</artifactId>
	<version>1.2.0.RELEASE</version>
</dependency>

io.projectreactor.kafka:reactor-kafka:1.2.0.RELEASE

<?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>io.projectreactor.kafka</groupId>

  <artifactId>reactor-kafka</artifactId>

  <version>1.2.0.RELEASE</version>

  <name>Reactor Kafka: A reactive API for Apache Kafka</name>

  <description>Reactor Kafka: A reactive API for Apache Kafka</description>

  <url>https://github.com/reactor/reactor-kafka</url>

  <organization>

    <name>reactor</name>

    <url>https://github.com/reactor</url>

  </organization>

  <licenses>

    <license>

      <name>The Apache Software License, Version 2.0</name>

      <url>https://www.apache.org/licenses/LICENSE-2.0.txt</url>

      <distribution>repo</distribution>

    </license>

  </licenses>

  <developers>

    <developer>

      <id>rsivaram</id>

      <name>Rajini Sivaram</name>

      <email>rsivaram@pivotal.io</email>

    </developer>

    <developer>

      <id>OlegDokuka</id>

      <name>Oleh Dokuka</name>

      <email>oleh.dokuka@icloud.com</email>

    </developer>

  </developers>

  <scm>

    <connection>scm:git:git://github.com/reactor/reactor-kafka</connection>

    <developerConnection>scm:git:git://github.com/reactor/reactor-kafka</developerConnection>

    <url>https://github.com/reactor/reactor-kafka</url>

  </scm>

  <issueManagement>

    <system>GitHub Issues</system>

    <url>https://github.com/reactor/reactor-kafka/issues</url>

  </issueManagement>

  <dependencies>

    <dependency>

      <groupId>io.projectreactor</groupId>

      <artifactId>reactor-core</artifactId>

      <version>3.3.0.RELEASE</version>

      <scope>compile</scope>

    </dependency>

    <dependency>

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

      <artifactId>kafka-clients</artifactId>

      <version>2.0.0</version>

      <scope>compile</scope>

    </dependency>

  </dependencies>

</project>

META-INF/MANIFEST.MF
reactor.kafka.sender.TransactionManager.class
reactor.kafka.sender.SenderRecord.class
reactor.kafka.sender.MutableSenderOptions.class
reactor.kafka.sender.KafkaSender.class
reactor.kafka.sender.KafkaOutbound.class
reactor.kafka.sender.SenderOptions.class
reactor.kafka.sender.ImmutableSenderOptions.class
reactor.kafka.sender.internals.DefaultKafkaSender$SendSubscriberNoResponse.class
reactor.kafka.sender.internals.DefaultKafkaSender$2.class
reactor.kafka.sender.internals.DefaultKafkaSender$SubscriberState.class
reactor.kafka.sender.internals.DefaultKafkaSender$AbstractSendSubscriber.class
reactor.kafka.sender.internals.DefaultKafkaSender$Response.class
reactor.kafka.sender.internals.DefaultKafkaSender$KafkaOutboundThen.class
reactor.kafka.sender.internals.DefaultKafkaSender$SendSubscriber.class
reactor.kafka.sender.internals.DefaultKafkaSender$DefaultTransactionManager.class
reactor.kafka.sender.internals.DefaultKafkaSender$DefaultKafkaOutbound.class
reactor.kafka.sender.internals.DefaultKafkaSender$1.class
reactor.kafka.sender.internals.DefaultKafkaSender.class
reactor.kafka.sender.internals.ProducerFactory.class
reactor.kafka.sender.SenderResult.class
reactor.kafka.receiver.ReceiverOffset.class
reactor.kafka.receiver.MutableReceiverOptions.class
reactor.kafka.receiver.ImmutableReceiverOptions.class
reactor.kafka.receiver.ReceiverPartition.class
reactor.kafka.receiver.ReceiverOptions.class
reactor.kafka.receiver.KafkaReceiver.class
reactor.kafka.receiver.ReceiverRecord.class
reactor.kafka.receiver.internals.DefaultKafkaReceiver.class
reactor.kafka.receiver.internals.KafkaSchedulers.class
reactor.kafka.receiver.internals.KafkaSchedulers$EventScheduler$EventWorker.class
reactor.kafka.receiver.internals.KafkaSchedulers$1.class
reactor.kafka.receiver.internals.CommittableBatch.class
reactor.kafka.receiver.internals.DefaultKafkaReceiver$AtmostOnceOffsets.class
reactor.kafka.receiver.internals.DefaultKafkaReceiver$1.class
reactor.kafka.receiver.internals.DefaultKafkaReceiver$AckMode.class
reactor.kafka.receiver.internals.DefaultKafkaReceiver$PollEvent.class
reactor.kafka.receiver.internals.ConsumerFactory.class
reactor.kafka.receiver.internals.CommittableBatch$CommitArgs.class
reactor.kafka.receiver.internals.DefaultKafkaReceiver$CommitEvent.class
reactor.kafka.receiver.internals.DefaultKafkaReceiver$CloseEvent.class
reactor.kafka.receiver.internals.SeekablePartition.class
reactor.kafka.receiver.internals.KafkaSchedulers$EventThreadFactory$EmitterThread.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)