Trait nakadion::ReadsStream [−] [src]

pub trait ReadsStream {
    type StreamingSource: Read;
    fn read(
        &self, 
        subscription: &SubscriptionId
    ) -> ClientResult<(Self::StreamingSource, StreamId)>;
}

Connects to Nakadi and reads the stream-

Associated Types

Required Methods

Attempts to get data from the stream. Also returns the StreamId which must be used for checkpointing.

Starts a new stream for reading events from this subscription. The data will be automatically rebalanced between streams of one subscription. The minimal consumption unit is a partition, so it is possible to start as many streams as the total number of partitions in event-types of this subscription. The rebalance currently only operates with the number of partitions so the amount of data in event-types/partitions is not considered during autorebalance. The position of the consumption is managed by Nakadi. The client is required to commit the cursors he gets in a stream.

Implementors