Akka.Streams.Kafka v1.0.0-beta1

1.0.0-beta1 November 27 2019

First beta release of Akka.Streams.Kafka

In this release, library was rewritten almost completely.
Conceptually, the main part of this release is implementing all consuming and producing stages supported in Alpakka project: https://github.com/akka/alpakka.
See #36 for full list of implemented stages (there are 11 consumer and 3 producer stages implemented).

Transactional stages are partially implemented, but waiting for issue #85 to be resolved
(which in turn is waiting for issue in Confluent driver to be closed).

Among the others improvements, some critical issues were resolved, like

• Get rid of internal buffering and scheduled pooling in Consumer stages (#35)
• DrainControl class is implement, which allows to shutdown stages from outside (so does not require source to be finished to stop processing)

Akka.Streams.Kafka v0.5.0 Beta

0.5.0 August 7 2019

Early release version of Akka.Streams.Kafka. This library is going to be rewritten to comport with Kafka and Akka.NET best practices, but it's available for use now.