KO | EN

GitLite

Minimalist Open Source Repository Search Engine

gitlite — search

#dsh #ai-agents #dsh-plugin #codex #developer-tools #claude-code #windows #desktop-app #typescript #rust #ai-agent #cli

reactor-kafka

★ 620 Open GitHub ↗

Reactive Kafka Driver with Reactor

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

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](https://spring.io/blog/2025/05/20/reactor-kafka-discontinued). The OSS and Enterprise Support Timeline can be found [here](https://projectreactor.io/support).**

[![Join the chat at https://gitter.im/reactor/reactor](https://badges.gitter.im/Join%20Chat.svg)](https://gitter.im/reactor/reactor?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge&utm_content=badge)
[![Travis CI](https://img.shields.io/travis/reactor/reactor-kafka.svg)](https://travis-ci.org/reactor/reactor-kafka)
[![Coverage](https://img.shields.io/codecov/c/github/reactor/reactor-kafka.svg)](https://travis-ci.org/reactor/reactor-kafka)

You need to have [Java 8](https://www.oracle.com/technetwork/java/javase/downloads/index.html) 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](reactor-kafka-samples/src/main/java/reactor/kafka/samples/SampleProducer.java) for sample reactive producer.
See [SampleConsumer.java](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:
```groovy
    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](https://github.com/reactor/reactor-kafka/issues)

### License ###

Reactor Kafka is [Apache 2.0 licensed](https://www.apache.org/licenses/LICENSE-2.0.html).

reactor-kafka

Explore Similar Repositories

Was this content helpful?

Recent Feedback

Download README