Package com.infinyon.fluvio

  • Class Summary
    Class Description
    Fluvio
    The Fluvio Java client for interacting with Fluvio streams from Java.
    FluvioError  
    Offset
    Describes the position of a record in a Fluvio partition.
    PartitionConsumer
    Create streams to read records from specific Fluvio topics and partitions.
    PartitionConsumerStream
    A stream that yields records from the origin topic and partition, starting at the given offset.
    Record
    Carries the data (key and value) for a Record in a Fluvio stream.
    TopicProducer
    Sends records to a particular topic.