Crate nakadion [−] [src]

WARNING! This is the fist iteration of a rewrite. API might change and features will be added. Documentation not yet updated!

Modules

Consumer	The consumer connects to the stream and sends batch lines to the processor.
EventType	The `Nakadi Event Type`. Similiar to a topic.
FlowId	A `StreamId` identifies a subscription. It must be provided for checkpointing with a `Cursor`.
Nakadion
NakadionBuilder
NakadionConfig	Settings for establishing a connection to `Nakadi`.
PartitionId	A partition id that comes with a `Cursor`
StreamId	A `StreamId` identifies a subscription. It must be provided for checkpointing with a `Cursor`.
SubscriptionId	A `SubscriptionId` is used to guarantee a continous flow of events for a client.

CommitStrategy	Stragtegy for committing cursors
ProcessingStatus
SubscriptionDiscovery
TypedProcessingStatus