reactor / Reactor Kafka
Reactive Kafka Driver with Reactor
Stars: ✭ 305
Programming Languages
java
68154 projects - #9 most used programming language
Reactor Kafka
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:
- Start Zookeeper and Kafka server
- Create topic "demo-topic"
To run sample producer:
- Update BOOTSTRAP_SERVERS and TOPIC in SampleProducer.java if required
- Compile and run reactor.kafka.samples.SampleProducer (eg. from IDE as a Java application))
To run sample consumer:
- Update BOOTSTRAP_SERVERS and TOPIC in SampleConsumer.java if required
- 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.3"
// compile "io.projectreactor.kafka:reactor-kafka:1.3.4-SNAPSHOT"
}
Community / Support
License
Reactor Kafka is Apache 2.0 licensed.
Note that the project description data, including the texts, logos, images, and/or trademarks,
for each open source project belongs to its rightful owner.
If you wish to add or remove any projects, please contact us at [email protected].