Overview (Reactor Kafka 1.3.19-SNAPSHOT)

Packages
Package	Description
reactor.kafka.receiver	Reactor Kafka Receiver API
reactor.kafka.sender	Reactor Kafka Sender API

This document is the API specification for the Reactor Kafka library.

Reactor Kafka is a reactive API for Apache Kafka based on Project Reactor. Reactor Kafka API enables messages to be published to Kafka topics and consumed from Kafka topics using functional APIs with non-blocking back-pressure and very low overheads. This enables applications using Reactor to use Kafka as a message bus or streaming platform and integrate with other systems to provide an end-to-end reactive pipeline.

KafkaSender

    sender.send(Flux.range(1, 10).map(i -> SenderRecord.create(new ProducerRecord<>(topic, i, "Message_" + i)), i))
          .doOnNext(r -> log.debug("Message #{} result: {}", r.correlationMetadata(), r.recordMetadata()))
          .subscribe();

KafkaReceiver

    receiver.receive()
            .subscribe(r -> {
                log.info("Received message {} ", r);
                r.receiverOffset().acknowledge();
            });

More detailed documentation is available in the Reference Guide.