You need to have Java 8 installed.
./gradlew jar
./gradlew test
./gradlew eclipse
./gradlew idea
See SampleProducer.java for sample reactive producer. See SampleConsumer.java for sample reactive consumer.
- Start Zookeeper and Kafka server
- Create topic "demo-topic"
- Update BOOTSTRAP_SERVERS and TOPIC in SampleProducer.java if required
- Compile and run reactor.kafka.samples.SampleProducer (eg. from IDE as a Java application))
- Update BOOTSTRAP_SERVERS and TOPIC in SampleConsumer.java if required
- Run reactor.kafka.samples.SampleConsumer (eg. from IDE as a Java application))
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.15"
// compile "io.projectreactor.kafka:reactor-kafka:1.3.16-SNAPSHOT"
}
Reactor Kafka is Apache 2.0 licensed.