Alpakka Kafka Connector v0.21
Update 2018-06-14: Please use the Hotfix v0.21.1 of this release!
On behalf of the Alpakka team and the whole extended community team, we are happy to announce a new Alpakka Kafka connector release which contains a number of new features, bug fixes and quite a few documentation improvements.
New features
- Support for Kafka Transactions #369 by @seglo
- Support for Metadata #422, original PR by @dsitte-h
- Support for flexible message types #415
Bug fixes
- a fix for when there are pending requests while closing partitions #466 by @dvallejo
- a fix for when there are no messages in a topic by a given timestamp #494
- a fix for pending confirmations counter in the producer stage #453 by @patrick-premont
- a fix for when sub-sources were not being stopped when the consumer was stopped #449
- a fix for consumer allowing a refresh the committed offset when there are no new messages #375 by @rtimush
The list of all closed tickets.
The list of all merged PRs.
Supported versions
The Alpakka Kafka Connector 0.21 is available for Scala 2.11 and Scala 2.12 and is uses on Akka 2.5.13.
It supports Kafka versions 0.11.x up to the current 1.1.x series.
This release is binary compatible with 0.20 as validated by MiMa.
Contributors
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
 ennru |
38 | 4400 | 2347 |
 2m |
8 | 427 | 164 |
 seglo |
5 | 1287 | 226 |
 ktoso |
4 | 4 | 4 |
 rtimush |
2 | 314 | 45 |
 sullis |
2 | 2 | 1 |
 dsitte-h |
1 | 397 | 2 |
 svroonland |
1 | 140 | 6 |
 jjst |
1 | 76 | 157 |
 dvallejo |
1 | 58 | 20 |
 raboof |
1 | 4 | 25 |
 Philippus |
1 | 1 | 1 |
 jeroenr |
1 | 1 | 1 |
 rafalmag |
1 | 1 | 1 |
 patrick-premont |
1 | 1 | 1 |