You need to have Gradle 2.0 or higher and Java 8 installed.
cd reactor-kafka
gradle wrapper
./gradlew jar
./gradlew test
./gradlew eclipse
./gradlew idea
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 producer.
- 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))
Reactor Kafka is Apache 2.0 licensed.