The Fluvio Java client for interacting with Fluvio streams from Java.
The Fluvio class does not provide a public constructor, instead it provides a static function that first connects to the target cluster and then returns a Fluvio object, representing a successfully-opened connection. If Fluvio fails to connect to a cluster, an exception will be thrown instead.
Fluvio fluvio = new Fluvio();
The cluster that the client connects to is determined by the active profile configured by the Fluvio CLI. Make sure you have followed the getting started guide and used the CLI to successfully connect to a running cluster, either on Fluvio Cloud or running locally.
Once a Fluvio object is created, it may be used to obtain a
PartitionConsumer, which may be used to send and receive records,
Method SummaryModifier and TypeMethodDescription
consumerpublic final PartitionConsumer consumer
(String topic, int partition) throws Exception
producerpublic final TopicProducer producer
(String topic) throws Exception
deletepublic void delete()
finalizeprotected void finalize() throws Throwable