Geek Culture
Published in

Geek Culture

Reactor Kafka Driver

Reactor Kafka is a reactive API for Kafka based on Reactor and the Apache Kafka Producer/Consumer API. Reactor Kafka API enables messages to be published to Kafka and consumed from Kafka using functional APIs with non-blocking back-pressure and very low overheads.

In this article, we discuss the Reactor Kafka API in depth. We look at consumption, production scenarios, pipelining, transactional send and threading model.

Reactor Kafka Receiver

The KafkaReceiver interface

--

--

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store
Kondah Mouad

Kondah Mouad

Cyber Security and Software Engineer, Machine Learning Guru