Skip to content
Reactive Kafka Client for Vert.x
Java Shell
Branch: master
Clone or download

Latest commit

Fetching latest commit…
Cannot retrieve the latest commit at this time.


Type Name Latest commit message Commit time
Failed to load latest commit information.

Vert.x Kafka Client

Build Status

This component provides a Kafka client for reading and sending messages from/to an Apache Kafka cluster. From the consumer point of view, its API provides a bunch of methods for subscribing to a topic partition receiving messages asynchronously or reading them as a stream (even with the possibility to pause the stream itself). As producer, its API provides methods for sending message to a topic partition like writing on a stream.

See the online docs for more details:

Important aspects of Topic Management, such as creating a topic, deleting a topic, changing configuration of a topic, are also supported. See the online docs for more details:

Note: This module has Tech Preview status, this means the API can change between versions.

You can’t perform that action at this time.