Reactor Kafka

NOTICE

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.

Building Reactor Kafka jars

./gradlew jar

Running unit tests

./gradlew test

Building IDE project

./gradlew eclipse
./gradlew idea

Sample producer and consumer

See SampleProducer.java for sample reactive producer. See 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 'https://repo.spring.io/snapshot' }
      // maven { url 'https://repo.spring.io/milestone' }
      mavenCentral()
    }

    dependencies {
      compile "io.projectreactor.kafka:reactor-kafka:1.3.25"
      // compile "io.projectreactor.kafka:reactor-kafka:1.3.26-SNAPSHOT"
    }

Community / Support

• GitHub Issues

License

Reactor Kafka is Apache 2.0 licensed.