Alpakka Kafka Connector v0.21.1

Hotfix release

Bug fixes

• An unwanted dependency became a transitive dependency of the Alpakka Kafka connector #504 - thanks to @schoeneu for reporting

The list of all closed tickets.
The list of all merged PRs.

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

v0.20

See details of this release in the milestone: https://github.com/akka/reactive-kafka/milestone/20?closed=1

Highlights:

• Kafka 1.0 support #366
• Consumer metrics exposed in Control materialized value #338
• Ability to listen for Consumer rebalance events #421

0.8.8

Fix incorrect manual commits after consumer rebalance (#141)

0.8.7

Fixes critical bug with Publisher failing on serialization (#84)

0.8.6

• Fix for partitioner issue with Array hashCode (#84)
• Fix issues with re-committing offsets that were already committed (thx @pbarron!)
• Switch to Akka 2.4.4 and scala-logging 3.1.0

0.10.1

This is a bugfix release with a major fix for #118

0.10.0

• Switched to Akka 2.4.2 by kerr (@hepin1989)
• Dropped Scala 2.10 support
• Switched to Kafka Client 0.9.0.1
• Fixed issues with stopping KafkaActorPublisher. Use KafkaActorPublisher.Stop now instead of ActorPublisherMessage.Cancel in order to stop manually.
  by Alexey Romanchuk (@13h3r)
• Fix: cancel upstream if producer reports sending failure by Piotr Jarzemski (@kazuhiro)
• Added 'clientId' to ConsumerProperties
• Other fixes and improvements (docs, examples) by Asko Kauppi (@akauppi) and Coty Rosenblath

Also, this release contains new GraphStage - based API. Please note that this is intermediary API and it will be rebuilt with future releases. Many thanks to Asko Kauppi, Alexey Romanchuk and Mike Krumlauf (@mjkrumlauf) for contributing to these efforts.

0.8.5

• Based on Akka 2.4.2 (Scala 2.10 support dropped)
• Some minor bugfixes

This release also includes initial support for GraphStage-based API but it's not recommended to use due to a major rebuild process which is still ongoing (see https://github.com/13h3r/reactive-kafka/blob/wip/api-ideas/docs/NewAPI.md for details).

0.9.0

• Switch to Kafka 0.9.0.0
• Switch to Akka Streams 2.0