v0.8.0

This is an improvement release

Improvements

• Reduce dramatically the performance impact of backpressure handling
• Add support of source and sink connectors.

The initial support for applicative connectors allows for easy integration with additional sources and sinks of data (others than Kafka).

v0.7.1

This is an improvement release.

It adds the support of ordered reads on the partitions of each topic. This feature is needed on applications that need total ordering on a whole topic and not only each partition. This is enabled by providing a timestamp_mapper function in the configuration. When a mapper is provided, makinage will read records of each partition with respect to increasing timestamps.
Note that total ordering is not guaranteed, but respected as much as possible: Within each partition, the records are emitted in their original order.

v0.7.0

This is an improvement release.

It adds the support of ordered reads on the partitions of each topic. This feature is needed on applications that need total ordering on a whole topic and not only each partition. This is enabled by providing a timestamp_mapper function in the configuration. When a mapper is provided, makinage will read records of each partition with respect to increasing timestamps.
Note that total ordering is not guaranteed, but respected as much as possible: Within each partition, the records are emitted in their original order.