Skip to content

langrp/reactor-kafka

 
 

Repository files navigation

Reactor Kafka

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 reactor-kafka-samples/src/main/java/reactor/kafka/samples/SampleProducer.java for sample reactive producer. See 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:

    repositories {
      //maven { url 'https://repo.spring.io/snapshot' }
      //maven { url 'https://repo.spring.io/milestone' }
      mavenCentral()
    }

    dependencies {
      //compile "io.projectreactor.kafka:reactor-kafka:1.2.2.BUILD-SNAPSHOT"
      compile "io.projectreactor.kafka:reactor-kafka:1.2.1.RELEASE"
    }

Community / Support

License

Reactor Kafka is Apache 2.0 licensed.

About

Reactive Kafka Driver with Reactor

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages

  • Java 56.9%
  • CSS 43.0%
  • HTML 0.1%