Folders and files

Name		Name	Last commit message	Last commit date
Latest commit History 492 Commits
.github		.github
codequality		codequality
docs/src/docs/dist		docs/src/docs/dist
gradle		gradle
reactor-kafka-samples/src		reactor-kafka-samples/src
reactor-kafka-tools/src		reactor-kafka-tools/src
src		src
.editorconfig		.editorconfig
.gitignore		.gitignore
LICENSE		LICENSE
NOTICE		NOTICE
README.md		README.md
build.gradle		build.gradle
gradle.properties		gradle.properties
gradlew		gradlew
gradlew.bat		gradlew.bat
settings.gradle		settings.gradle

Repository files navigation

Reactor Kafka

NOTICE

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

You need to haveJava 8 installed.

Building Reactor Kafka jars

./gradlew jar

Running unit tests

./gradlew test

Building IDE project

./gradlew eclipse./gradlew idea

Sample producer and consumer

SeeSampleProducer.java for sample reactive producer.SeeSampleConsumer.java for sample reactive consumer.

Setup Kafka cluster and create topic:

Start Zookeeper and Kafka server
Create topic "demo-topic"

To run sample producer:

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

To run sample consumer:

Update BOOTSTRAP_SERVERS and TOPIC in SampleConsumer.java if required
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.24"// compile "io.projectreactor.kafka:reactor-kafka:1.3.25-SNAPSHOT"    }