reactor/reactor-kafka

Reactive Kafka Driver with Reactor http://projectreactor.io

Download

Step 1. Add the JitPack repository to your build file

Add it in your root settings.gradle at the end of repositories:

	dependencyResolutionManagement {
		repositoriesMode.set(RepositoriesMode.FAIL_ON_PROJECT_REPOS)
		repositories {
			mavenCentral()
			maven { url 'https://jitpack.io' }
		}
	}

Add it in your settings.gradle.kts at the end of repositories:

	dependencyResolutionManagement {
		repositoriesMode.set(RepositoriesMode.FAIL_ON_PROJECT_REPOS)
		repositories {
			mavenCentral()
			maven { url = uri("https://jitpack.io") }
		}
	}

Add to pom.xml

	<repositories>
		<repository>
		    <id>jitpack.io</id>
		    <url>https://jitpack.io</url>
		</repository>
	</repositories>

Add it in your build.sbt at the end of resolvers:

 
    resolvers += "jitpack" at "https://jitpack.io"

Add it in your project.clj at the end of repositories:

 
    :repositories [["jitpack" "https://jitpack.io"]]

Step 2. Add the dependency

	dependencies {
		implementation 'com.github.reactor:reactor-kafka:1.4.0-RC1'
	}
	dependencies {
		implementation("com.github.reactor:reactor-kafka:1.4.0-RC1")
	}
	<dependency>
	    <groupId>com.github.reactor</groupId>
	    <artifactId>reactor-kafka</artifactId>
	    <version>1.4.0-RC1</version>
	</dependency>

                            
    libraryDependencies += "com.github.reactor" % "reactor-kafka" % "1.4.0-RC1"
        
        

                            
    :dependencies [[com.github.reactor/reactor-kafka "1.4.0-RC1"]]

Readme

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.

Join the chat at https://gitter.im/reactor/reactor Travis CI Coverage

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

License

Reactor Kafka is Apache 2.0 licensed.