fluvio._fluvio_python

class Fluvio:

Fluvio()

def connect(unknown):

def partition_consumer(unknown):

def topic_producer(unknown):

class ProducerBatchRecord:

ProducerBatchRecord()

def clone(unknown):

class TopicProducer:

TopicProducer()

def send(unknown):

def send_all(unknown):

def flush(unknown):

class Record:

Record()

def offset(unknown):

def value(unknown):

def key(unknown):

def value_string(unknown):

def key_string(unknown):

class Offset:

Offset()

def absolute(unknown):

def beginning(unknown):

def from_beginning(unknown):

def end(unknown):

def from_end(unknown):

class Cloud:

Cloud()

def new(unknown):

def get_auth0_url(unknown):

def authenticate_with_auth0(unknown):

def login_with_username(unknown):

class PartitionConsumer:

PartitionConsumer()

def stream(unknown):

def stream_with_config(unknown):

class PartitionConsumerStream:

PartitionConsumerStream()

def next(unknown):

class SmartModuleKind:

SmartModuleKind()

class SmartModuleContextData:

SmartModuleContextData()

class ConsumerConfig:

ConsumerConfig()

def smartmodule(unknown):