nakadion 0.7.8

A connector for the Nakadi Event Broker
Documentation

Nakadion

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!

Consuming

Nakadion supports two modes of consuming events. A sequuential one and a cuncurrent one.

Sequential Consumption

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.

Concurrent Consumption

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.

Performance

This library is not meant to be used in a high performance scenario. It uses synchronous IO.

Documentation

Documenatation can be found at docs.rs

License

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.