This page describes how to generally use any of the fluvie clients. Each client has some differences but these are the general rules about them.
For generated API Docs visit:
The first thing you want to do to use a fluvio client is connect to the fluvio cluster.
Once you’ve got a connection handler, you will want to create a producer for a given topic.
When sending into a stream, the general
send will take a
key and a
key is optional. For clients which don’t have
Option as a feature, this
is simply an empty array.
Depending on the client, these can be
string or an array of
Similar to a producing, once you’ve got a connection, you’ll need to create a consumer for a given topic.
Once you’ve got a consumer, you can create a stream given an offset and listen for new items.
Most of our clients support idiomatic ways of iterating over the items in the stream:
- The rust client stream uses a
- The node client stream implements the
- The python client stream implements
__next__making it a Python Iterator
This functionality has not been implemented for the java client yet.
An offset is used when a stream is created to request the stream to start at
N items from the beginning/end of the stream.
Each item in a stream is a
Our clients differ a little bit on this but a
Record is a wrapper around
array of bytes with accessor methods of
In the python, node and java clients, we have to-string convenience methods.