This package contains some utilities to work with Kafka in a reactive streams context. It provides a publisher that is backed by a Kafka consumer and a subscriber that uses a Kafka producer. At least once semantics are supported. See also the API documentation.