You need to have Java 8 installed.

./gradlew jar

./gradlew test

./gradlew eclipse
./gradlew idea

See SampleProducer.java for sample reactive producer. See SampleConsumer.java for sample reactive consumer.

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

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))

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

With Gradle from repo.spring.io:

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

    dependencies {
      // compile "io.projectreactor.kafka:reactor-kafka:1.4.0-SNAPSHOT"
      compile "io.projectreactor.kafka:reactor-kafka:1.4.0-M1"
    }

• GitHub Issues

Reactor Kafka is Apache 2.0 licensed.