A client for the Nakadi Event Broker.
Nakadion uses the Subscription API of Nakadi.
WARNING! This is the fist iteration of a rewrite. API might change and features will be added. Documentation not yet updated!
Nakadion supports two modes of consuming events. A sequuential one and a cuncurrent one.
In this mode Nakadion will read a batch from Nakadi then call a handler on theese and afterwards try to commit the batch. This mode of operation is simple, straight forward and should be sufficient for most scenarios.
In this mode Nakadion will spawn a number of worker threads and distribute work among them based on
the partion id of a batch. The workers are not dedidacted to a partition. Work is rather distributed based
on a hash of the partition id.
This library is not meant to be used in a high performance scenario. It uses synchronous IO.
Documenatation can be found at docs.rs
Nakadion is distributed under the terms of both the MIT license and the Apache License (Version 2.0).
See LICENSE-APACHE and LICENSE-MIT for details.