Reactor Kafka had been discontinued in May 2025. The team has laid out the reasons to discontinue the project in the announcement. The OSS and Enterprise Support Timeline can be found here.

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.3.23"
      // compile "io.projectreactor.kafka:reactor-kafka:1.3.24-SNAPSHOT"
    }

• GitHub Issues

Reactor Kafka is Apache 2.0 licensed.