Alpakka 1.0 Milestone 2

Release notes are to be found in the documentation: Alpakka Release Notes

Alpakka 1.0 Milestone 1

This is the first milestone release for Alpakka 1.0

Release notes are to be found in the documentation: Alpakka Release Notes

Alpakka v0.20

Highlights in this release

• New connector: HDFS #965 by @burakkose
• New connector: UDP #995 by @radekg
• New module: Text, supporting transcoding character sets #1011

We added a new module "reference" serving as an example implementation for Alpakka connectors. This module is meant to show and explain how Alpakka APIs should be built so that they can be Java and Scala friendly, and evolve in a binary compatible way.
#1039

Breaking API changes may have been introduced in several modules as the contributors refine the functionality in Alpakka.

Modules using Akka Http now use version 10.1.3. In case your code should stay on 10.0.13, exclude the Akka Http dependency from the Alpakka module. We aim to support the 10.0.13+ versions for a while.

Highlights per module

AMQP Connector

• see closed tickets

AWS Kinesis

• see closed tickets

AWS S3

• Support download of very large files #1036
• Support versioning #951 by @sfali
• see closed tickets

Cassandra

• see closed tickets

DynamoDb

• Improved Java API (API CHANGE) #1055
• see closed tickets

Elasticsearch

• Standardised to shared settings for Java and Scala (API CHANGE) #1009
• closed tickets

Google Cloud Pub-Sub

• see closed tickets

HBase

• Allow different and multiple mutations (API CHANGE) #1050 by @davideicardi
• see closed tickets

HDFS

• New connector #965 by @burakkose

MongoDB

• Use client version 2.3.0 #1041

UDP

• new connector #995 by @radekg

Unix Domain Socket

• ensure that interest in READ is removed upon EOF #1056

Everything done in this release is in the milestone.

General information

This release is tested against Akka 2.5, only.
The S3 and SSE connectors require at least Akka Http 10.0.13 and are compatible with Akka Http 10.1.1+.

This release was made possible by a lot of new and earlier contributors:

Author	Commits	Lines added	Lines removed
2m	19	1831	980
ennru	15	9201	7011
sullis	7	8	8
takezoe	3	138	221
juanjoDiaz	3	9	5
davideicardi	2	256	69
anzecesar	2	206	103
longshorej	2	44	41
burakkose	1	3273	1
radekg	1	576	0
sfali	1	397	79
hochgi	1	61	41
damianbl	1	49	7
adamtrousdale	1	30	25
gregbeech	1	17	12
randomcoder	1	13	8
cheleb	1	8	7
schrepfler	1	3	3
ahd985	1	2	8
CatTail	1	1	3
dana-harrington	1	1	3
mikela	1	1	1
lexn82	1	1	0
eed3si9n	1	1	0

Alpakka v0.19

Highlights in this release

• New connector: Apache Kudu #924
• New module: json-streaming supporting Json Path #942
• Reactive Kafka is now the Alpakka Kafka connector (will stay in its separate repository, though)
• snapshots are now made available every day https://developer.lightbend.com/docs/alpakka/current/other-docs/snapshots.md

Breaking API changes may have been introduced in several modules as the contributors refine the functionality in Alpakka.

Highlights per module

AMQP Connector

• release resources on shutdown #887
• support naming of connections #881

Apache Geode connector

• upgraded to Geode 1.5.0 #890

Apache Kudu

• new #924

AWS DynamoDB Connector

• parallel requests #877

AWS S3 Connector

• multipart copy support #943

FTP Connector

• support custom SSH configuration #875

JMS Connector

• create custom destination #867
• make sure commits get processed when stopping #905

Kafka

• 0.20 with Kafka 1.x support was release in April https://github.com/akka/reactive-kafka/releases/tag/v0.20

MongoDB Connector

• support insertMany #893

Unix Domain Socket Connector

• bug fixes

JSON

• the new Json-streaming support #942

Comma-Separated Values - CSV

• parser bug fixes

Everything done in this release is in the milestone.

General information

This release is tested against Akka 2.5, only.
The S3 and SSE connectors require at least Akka Http 10.0.13 and are compatible with Akka Http 10.1.1.

This release was made possible by a lot of new and earlier contributors:

Author	Commits	Lines added	Lines removed
ennru	16	1388	798
2m	7	232	102
juanjoDiaz	3	66	45
longshorej	3	28	7
sfali	1	1034	20
Sandish Kumar	1	540	0
markusthoemmes	1	420	3
drobert	1	193	7
russellyou	1	162	23
randomcoder	1	140	11
fmsbeekmans	1	73	4
bolshakov	1	50	0
akara	1	29	16
gregbeech	1	12	7
tuleism	1	12	1
anilgursel	1	9	1
cheleb	1	8	8
pliljenberg	1	6	2
lexn82	1	3	1

Alpakka v0.18

Highlights in this release

• New: Google Firebase Cloud Messaging
• New: AWS Kinesis Firehose
• JDK 9 module names

Breaking API changes have been introduced in several modules as the contributors refine the functionality in Alpakka.

Highlights per module

AMQP

• Fixes for connection handling

AWS Kinesis Firehose

• New connector within the Kinesis module

AWS S3

• content-length fix
• support content-type headers
• allow empty upload
• requires Akka Http 10.0.13
• support API v1 for List buckets

AWS SQS

• allow termination on empty queue
• batched acknowledgement

Cassandra

• support using unlogged batch to improve performance

Elasticsearch

• Support version-type attribute
• Use Jackson version 2.9.4 (was 2.9.1 before)

Google Firebase Cloud Messaging

• new connector

JMS

• Major API changes (JmsSource is now JmsConsumer, JmsSink is now JmsProducer)
• new flow support (in JmsProducer)
• improved shutting down of acknowledged consumers

MongoDB

• Use version 2.2.1 (was 2.1.0 before)
• Support generic types (not just Document)

MQTT

• more robust connection handling

Server-sent events - SSE

• requires Akka Http 10.0.13

Slick / JDBC

• create SlickSession from existing DatabaseConfig instance

Everything done in this release is in the milestone.

General information

This release is tested against Akka 2.5, only.
The S3 and SSE connectors require at least Akka Http 10.0.13 and will be compatible with Akka Http 10.1.1 (but not 10.1.0).

This release was made possible by a lot of new and earlier contributors:

Author	Commits	Lines added	Lines removed
ennru	13	603	138
juanjoDiaz	4	221	49
huntc	3	59	27
takezoe	3	21	15
gregbeech	2	781	21
tuleism	2	151	29
dwickern	1	1259	942
tg44	1	1086	1
aserrallerios	1	750	113
randomcoder	1	285	43
beikern	1	255	8
mikela	1	144	33
matthedude	1	79	28
eyalfa	1	78	13
Norwae	1	59	9
chetanmeh	1	25	5
hntd187	1	14	8
sksamuel	1	5	0
ktoso	1	1	1
Falmarri	1	1	1
sherzodv	1	1	0

Alpakka v0.17

Highlights in this release

• Connector for OrientDB

Breaking API changes have been introduced in several modules as the contributors refine the functionality in Alpakka.

Highlights per module

AMQP

• fix login

AWS S3

• make object metadata available on downloads
• fixed request signing
• fixed file handle leak

AWS SQS

• support message requests

Cassandra

• support for pass through

DynamoDB

• Support paging

Elasticsearch

• specify index per document
• more flexibility on index and type

Google cloud pub/sub

• support attributes and publish time

JMS

• queue browser source
• fixed connection closing

OrientDB

• new connector

Server-sent events - SSE

• fix cancel stragegy

Slick / JDBC

• add Flow and support pass through

Everything done in this release is in the milestone.

This release is tested against Akka 2.5, only. Most modules do still work fine with Akka 2.4, though.

This release was made possible by a lot of new and earlier contributors:

commits  added  removed
     13    729      649 Enno
      4    844      102 Morten Kjetland
      3      4        6 Arnout Engelen
      2    211        6 Derek Wickern
      2    100       29 Juanjo Diaz
      2      8        7 Naoki Takezoe
      1   1930        0 Burak KOSE
      1   1531        0 Subhobrata Dey
      1    475       12 Joost den Boer
      1    227       51 Random Coder
      1    200        1 Arun Manivannan
      1    155       35 Roman Timushev
      1     95       66 Nathaniel Fischer
      1    117       26 Viktor Lövgren
      1    137        4 José Luis Colomer Martorell
      1     67        0 Konrad `ktoso` Malawski
      1     41        6 Vladimir Malyk
      1     37        3 russellyou
      1     14       13 Jan Ypma
      1     20        3 Adriaan Groenenboom
      1      6        6 NOUGUIER Olivier
      1      3        1 Stefano Bonetti
      1      1        2 Yuriy Tumakha
      1      1        1 Martynas Mickevičius
      1      1        1 Heiko Seeberger

Alpakka v0.16 - 2018-01-11

Highlights in this release

• All new: the Unix Domain Socket Connector
• AWS S3 improvements
• More complex examples in the documentation

Highlights per module

AMQP

• support for connection re-use

AWS S3

• Support for more detailed configuration (encryption, custom endpoints)
• put object, delete object support

FTP

• Move and remove operations

JMS

• Support for more detailed configuration
• API improvements

Elasticsearch

• Flow now supports passThrough
• Support for Upsert

MQTT

• Manual acknowledge
• Support more detailed configuration

XML

• Namespace support

Find everything done in this release in the milestone.

This release is tested against Akka 2.5, only. Most modules do still work fine with Akka 2.4, though.

This release was made possible by a lot of new and earlier contributors:

commits  added  removed
     12   2308     1337 Juanjo Diaz
     10   2694      552 Enno
      5     10        6 Arnout Engelen
      2    897       59 Francis De Brabandere
      2    243       61 Ilia
      2     87       11 Michał Węgrzyn
      2      3        3 Martynas Mickevičius
      1   3135      165 Akara Sucharitakul
      1    968        0 Christopher Hunt
      1    754       72 Mariano Lischetti
      1    664        5 Mehmet Cem Gunturkun
      1    336      213 Morten Kjetland
      1    501       23 Jaap ter Woerds
      1    384       30 Korbik
      1    237       53 Nils-Helge Garli Hegvik
      1    223       61 Erik LaBianca
      1     90      179 Johan Andrén
      1    185       37 d2e8f9
      1    165       13 Łukasz Gołębiewski
      1    148       11 jmengoni
      1     51       13 Adriaan Groenenboom
      1     21        6 Jisoo Park
      1      7        6 Jules Ivanic
      1      5        5 Ilija Ljubicic
      1      3        4 Bartosz Kowalik
      1      2        2 Nikos Viorres

0.15.1: bugfix release: S3 signing broken due to week-based year formatting

This release contains a single commit (in addition to 0.15's state) that fixes the issue #680 discovered on December 31st 2017.

S3: Format x-amz-date with year-of-era (#679)

"YYYY" in DateTimeFormatter.ofPattern("YYYYMMdd") means
week-based-year, which formats LocalDate.of(2017, 12, 31) as
"20181231" and results in unexpected rejections from S3 as below.

This means that the the formatting would use the wrong year and cause errors similar to:

<Code>RequestTimeTooSkewed</Code><Message>The difference between the request time and the current time is too large.</Message><RequestTime>20181231T090017Z</RequestTime><ServerTime>2017-12-31T09:00:18Z</ServerTime>

Since the signature would be created with the wrong year.

This patch fixes this, by changing the date formatting from the mistakenly used YYYY to the correct yyyy. For details see: #680 as well as the rationale for the formattings: http://www.juandebravo.com/2015/04/10/java-yyyy-date-format

Credits

More information in the github milestone: https://github.com/akka/alpakka/milestone/18?closed=1

We would like to thank @guersam for quickly proposing a working fix for the issue:

commits  added  removed
      1     21        6 Jisoo Park

Alpakka Sinterklaas v0.15

Many parts of Alpakka got minor improvements, but here are some highlights:

DynamoDB

• Support TTL

Elasticsearch

• Object mapper now configurable

File

• File rotation sink (think loggfiles)

JMS

• Sink: other datatypes than Text
• API improvements

MongoDB

• Sink
• Flow

MQTT

• Flow

XML

• XML events to text writer

Or look at the full list of issues from this release

This is the last release to support the Akka 2.4 series.

This release was made possible by a lot of new and earlier contributors:

commits	added	removed	author
11	861	386	Enno
6	406	106	Martynas Mickevičius
5	143	45	Lomig Mégard
5	23	20	Christopher Batey
4	233	217	Arnout Engelen
3	176	27	Naoki Takezoe
2	724	43	Albert Serrallé Ríos
2	571	19	Gergő Törcsvári
1	894	154	d2e8f9
1	344	174	Michał Węgrzyn
1	429	8	Stephen Nancekivell
1	338	1	Korbik
1	171	16	Michal Matloka
1	94	44	David Knapp
1	56	5	Morten Kjetland
1	41	1	Greg Beech
1	8	6	olivier.nouguier
1	6	2	Roman Tkalenko
1	1	4	João Costa
1	2	2	andyoll
1	2	2	Stijn De Haes

v0.14: AMQP improvements and Spring Web support

The main improvements of this release are:

• Setting routing key per message in AMQP integration
• Provide support for Akka Streams in Spring MVC
• Make the Spring MVC/Boot integration provide "Auto Configuration"
• JMS header support on outgoing messages

For additional issues fixed and details see the list of closed issues

Thanks to the 9 contributors that made this release possible!

Author	Commits	Lines added	Lines removed
raboof	5	76	178
ktoso	3	270	63
juanjoDiaz	2	110	13
jonas	1	159	602
frederic-gendebien	1	139	6
johanandren	1	41	40
Guidoooch	1	23	2
takezoe	1	6	2
cheleb	1	2	2