Reactive Kafka Driver with Reactor
Java CSS XSLT HTML
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.

README.md

Reactor Kafka

Join the chat at https://gitter.im/reactor/reactor Travis CI Coverage

You need to have Java 8 installed.

Building Reactor Kafka jars

./gradlew jar

Running unit tests

./gradlew test

Building IDE project

./gradlew eclipse
./gradlew idea

Sample producer and consumer

See reactor-kafka-samples/src/main/java/reactor/kafka/samples/SampleProducer.java for sample reactive producer. See reactor-kafka-samples/src/main/java/reactor/kafka/samples/SampleConsumer.java for sample reactive consumer.

Setup Kafka cluster and create topic:

  1. Start Zookeeper and Kafka server
  2. Create topic "demo-topic"

To run sample producer:

  1. Update BOOTSTRAP_SERVERS and TOPIC in SampleProducer.java if required
  2. Compile and run reactor.kafka.samples.SampleProducer (eg. from IDE as a Java application))

To run sample consumer:

  1. Update BOOTSTRAP_SERVERS and TOPIC in SampleConsumer.java if required
  2. Run reactor.kafka.samples.SampleConsumer (eg. from IDE as a Java application))

To build applications using reactor-kafka API:

With Gradle from repo.spring.io:

    repositories {
      //maven { url 'http://repo.spring.io/snapshot' }
      maven { url 'http://repo.spring.io/milestone' }
      mavenCentral()
    }

    dependencies {
      //compile "io.projectreactor.kafka:reactor-kafka:1.0.1.BUILD-SNAPSHOT"
      compile "io.projectreactor.kafka:reactor-kafka:1.0.0.RELEASE"
    }

Community / Support

License

Reactor Kafka is Apache 2.0 licensed.