Alpakka 2.0.x
The major version tick for Alpakka is due to major upgrades and changes in the dependencies used by the various connectors. Some Alpakka APIs changed as well, but we try to keep those changes minimal.
To understand the forces on version numbers, read about Alpakka’s versioning scheme.
In case you are browsing a specific version’s documentation: check out the latest release notes
All Alpakka modules are available for Scala 2.13 and all Alpakka modules are compatible with Akka 2.6.8+ and Akka 2.5.31+. An exception is MQTT streaming which is available for Akka 2.6 only.
2.0.2
Released 2020-09-17
Notable changes compared to 2.0.1
- NEW MODULE: Google bigquery #2252 by @gkatzioura
- Slick/JDBC: Support
PreparedStatementuse in Java DSL #2318 by @ihostage - Kinesis KCL: let source backpressure correctly #2377 by @aserrallerios
- AWS S3: Add access-style property (to support path-style access for non-AWS S3 services)#2392 by @laszlovandenhoek
-
Patch version upgrades across the board #2414 by @ennru (affects Avro Parquet, AWS Event Bridge, AWS Lambda, AWS S3, AWS SNS, AWS SQS, Couchbase, Dynamodb, Elasticsearch, HBase, JMS, Kinesis, MQTT, Orientdb, Slick, Solr, Spring Web)
- Jackson 2.10.5 where Jackson appears transitively (to get the latest security fixes) #2373 by @ennru
Infrastructure
- sbt 1.13.3, latest JDKs, latest test libs, fewer CI steps #2412 by @ennru
- tests: disable parallel execution #2411 by @ennru
- doc: Alpakka Kafka 2.0.5 in the patterns section #2398 by @ennru
- docs: least Akka 2.6 version from the scheduled build #2397 by @ennru
- Scala to 2.12.11 and 2.13.2 and silencer 1.7.0 #2286 by @raboof
- Build against Akka 2.6.8 on Travis nightlies #2393 by @raboof
- docs: Spelling #2375 by @ennru
- Akka HTTP 10.2 in the scheduled build #2374 by @ennru
- Update paradox akka to 0.35, new links to LB.com #2367 by @johanandren
- build: plugin updates #2351 by @ennru
- Amend contributor advice around javadsl function types #2359 by @raboof
Contributors for 2.0.2
Alpakka gets a lot of contributions - some small, some huge. It’s great to see so many people working together to create useful integrations with Akka Streams.
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
 gkatzioura |
201 | 5615 | 3916 |
 ennru |
22 | 586 | 319 |
 tg44 |
5 | 3381 | 864 |
 raboof |
5 | 91 | 136 |
 laszlovandenhoek |
2 | 139 | 64 |
 cheleb |
2 | 5 | 5 |
 ihostage |
1 | 362 | 118 |
 aserrallerios |
1 | 278 | 72 |
 bgahagan |
1 | 172 | 1 |
 karlssonsimon |
1 | 90 | 75 |
 K-Adnan |
1 | 84 | 33 |
 mpdn |
1 | 68 | 0 |
 shagoon |
1 | 47 | 0 |
 mas15 |
1 | 21 | 0 |
 Grandys |
1 | 17 | 1 |
 yannisf |
1 | 1 | 1 |
 johanandren |
1 | 1 | 1 |
2.0.1
Released 2020-06-09
Notable changes compared to Alpakka 2.0.1
New Connector: AWS EventBridge
AWS Kinesis
- diverse improvements by @vaslabs, @matsluni and @YikSanChan
See AWS Kinesis for details.
AWS S3
Cassandra
Comma-separated Values (CSV)
Elasticsearch
- Support the routing parameter #2272 by @yannisf
- ElasticsearchSource: Clear Scroll On Exhaustion or Completion #2330 by @michaeljmarshall
- Support
allow_explicit_index: false#2326 by @mrooding - Add createBulk factory methods #2306 by @KGoodale13
File
- Allow LogRotatorSink be a Sink[T] instead of Sink[ByteString] [#2323](https://github.com/akka/alpakka/issues/2323) by @shagoon
- file/tar: Allow space as terminal character in tar header #2325 by @sberglann
Contributors
Alpakka gets a lot of contributions - some small, some huge. It’s great to see so many people working together to create useful integrations with Akka Streams.
Contributors since Alpakka 2.0.1:
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
 YikSanChan |
7 | 33 | 54 |
| ennru |
2 | 102 | 39 |
 KGoodale13 |
2 | 91 | 0 |
 bpiper |
2 | 3 | 3 |
 teroxik |
1 | 930 | 1 |
 vaslabs |
1 | 140 | 43 |
| shagoon |
1 | 77 | 11 |
 mrooding |
1 | 56 | 15 |
 michaeljmarshall |
1 | 52 | 1 |
 iRevive |
1 | 50 | 60 |
 sberglann |
1 | 21 | 1 |
| yannisf |
1 | 9 | 2 |
 tst60 |
1 | 6 | 1 |
 chbatey |
1 | 3 | 9 |
 matsluni |
1 | 1 | 1 |
 vigoo |
1 | 0 | 26 |
2.0.0
Released 2020-04-30
Notable changes compared to Alpakka 1.1.x
- Alpakka 2.0 updates dependencies for most connectors.
- Alpakka 2.0 requires Akka 2.5.31 or Akka 2.6.4. We recommend upgrading your projects to the latest versions of Akka.
- Many Alpakka APIs haven’t changed since Alpakka 1.0. We hope adapting to the changes will be easy. For the time being we don’t have dedicated migration guides. Please reach out in the Discuss forum if you run into problems.
Major new functionality
-
Pravega connector #2149 by @cheleb
Pravega provides a new storage abstraction - a stream - for continuous and unbounded data. A Pravega stream is an elastic set of durable and append-only segments, each segment being an unbounded sequence of bytes. Streams provide exactly-once semantics, and atomicity for groups of events using transactions.
-
Cassandra: rewrite on top of Java driver 4.5.0 #2182 by @ennru Alpakka Cassandra is completely rewritten and now based on the Cassandra Java driver version 4.6. It now becomes the base for Akka Persistence Cassandra.
-
AWS Kinesis KCL streams support #1667 by @aserrallerios
-
Elasticsearch
-
File
- TAR archive generation #2241 by @choffmeister
- TAR archive reader #2268 by @ennru
- Added flow for creating file ZIP archive #1890 by @michalbogacz
The way forward
The Alpakka community is encouraged to continue to suggesting improvements and new functionality to the existing connectors, or even suggest integrations with other technologies. During Alpakka 2.0 we will keep the APIs binary-compatible.
We even have contributions for new connectors on their way in. We’ll try to cut patch releases whenever something of relevance gets merged.
Contributors
Alpakka gets a lot of contributions - some small, some huge. It’s great to see so many people working together to create useful integrations with Akka Streams.
Contributors since Alpakka 1.1.3:
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
| ennru |
120 | 15290 | 8988 |
| raboof |
14 | 641 | 555 |
 2m |
10 | 892 | 423 |
 seglo |
10 | 430 | 160 |
 harshalveera |
10 | 103 | 73 |
| cheleb |
6 | 1658 | 54 |
 LGLO |
5 | 524 | 161 |
 michalbogacz |
4 | 708 | 105 |
 ignasi35 |
4 | 308 | 308 |
 francisdb |
3 | 980 | 171 |
| bpiper |
3 | 650 | 180 |
 jphelp32 |
3 | 222 | 13 |
 huntc |
3 | 204 | 72 |
 sullis |
3 | 3 | 3 |
| aserrallerios |
2 | 1272 | 57 |
 DanieleSassoli |
2 | 705 | 84 |
 nivox |
2 | 604 | 316 |
 btomala |
2 | 470 | 353 |
 paualarco |
2 | 311 | 213 |
 gabrielreid |
2 | 132 | 8 |
| mpdn |
2 | 66 | 58 |
 dotbg |
2 | 50 | 9 |
 kstrek |
1 | 1610 | 144 |
 r-glyde |
1 | 1330 | 1218 |
 an-tex |
1 | 530 | 68 |
| vigoo |
1 | 488 | 81 |
 choffmeister |
1 | 478 | 21 |
| Regis Kuckaertz | 1 | 460 | 1037 |
 longshorej |
1 | 374 | 217 |
 RomanLebid |
1 | 361 | 81 |
 jewertow |
1 | 333 | 42 |
 mjp426 |
1 | 326 | 16 |
 mdibaiee |
1 | 160 | 12 |
 janjaali |
1 | 135 | 58 |
 andreas-schroeder |
1 | 132 | 68 |
 dwickern |
1 | 92 | 12 |
| KGoodale13 |
1 | 81 | 1 |
 jcroig |
1 | 79 | 86 |
 Kreinoee |
1 | 55 | 16 |
 sturmin |
1 | 22 | 1 |
| tg44 |
1 | 17 | 21 |
 anzecesar |
1 | 15 | 6 |
 dl-mai |
1 | 14 | 1 |
 MrRexZ |
1 | 10 | 7 |
| Tim Moore | 1 | 9 | 32 |
 shimamoto |
1 | 8 | 11 |
 pecorarista |
1 | 4 | 2 |
 touchdown |
1 | 2 | 2 |
 wi101 |
1 | 1 | 1 |
 ldrygala |
1 | 1 | 1 |
 ashwanthkumar |
1 | 1 | 1 |
| laszlovandenhoek |
1 | 1 | 1 |
2.0.0-RC2
Released 2020-04-06
Notable changes since 2.0.0-RC1
-
Pravega connector #2149 by @cheleb
Pravega provides a new storage abstraction - a stream - for continuous and unbounded data. A Pravega stream is an elastic set of durable and append-only segments, each segment being an unbounded sequence of bytes. Streams provide exactly-once semantics, and atomicity for groups of events using transactions.
-
File: TAR archive generation #2241 by @choffmeister
-
Akka 2.5.31 and make Alpakka accept both classic and typed actor systems #2254 by @ennru
This release candidate contains changes from 8 contributors in the Alpakka community. Thank you all!
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
| ennru |
14 | 306 | 210 |
| cheleb |
3 | 1646 | 19 |
| choffmeister |
1 | 478 | 21 |
| aserrallerios |
1 | 66 | 21 |
| btomala |
1 | 66 | 20 |
| MrRexZ |
1 | 10 | 7 |
| raboof |
1 | 2 | 2 |
| paualarco |
1 | 1 | 1 |
2.0.0-RC1
Released 2020-03-20
Notable changes since 2.0.0-M3
Alpakka Cassandra is completely rewritten and now based on the Cassandra Java driver version 4.6. It now becomes the base for Akka Persistence Cassandra.
The MQTT Streaming connector does only support Akka 2.6 now.
- AWS S3: virtual-host-style access with endpoint URL #2193 by @ennru
- AWS S3: Retry multipart chunk uploads on transient errors using RetryFlow #2116 by @bpiper
- Google Cloud Pub/Sub gRPC: Akka gRPC 0.8.0, hide materializer, support new actors API #2198 by @ennru
- MongoDB: replaceOne operation #2187 by @jewertow
This release candidate contains changes from 8 contributors in the Alpakka community. Thank you all!
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
| ennru |
22 | 3738 | 1292 |
| seglo |
4 | 155 | 141 |
| raboof |
3 | 48 | 16 |
| bpiper |
2 | 639 | 171 |
| francisdb |
2 | 185 | 79 |
| jewertow |
1 | 333 | 42 |
| mdibaiee |
1 | 160 | 12 |
| ignasi35 |
1 | 3 | 2 |
2.0.0-M3
Released 2020-02-20
Notable changes in 2.0.0-M3
- Require Akka 2.6.1 or 2.5.27 and Akka HTTP 10.1.11 (where it is used) #2071 by @touchdown
- AWS Kinesis KCL streams support #1667 by @aserrallerios
- AWS S3: change default to virtual-host-style access #2099 by @ennru
- Google Storage & Pub-Sub: Retry google token requests on 5xx #2146 by @francisdb
- MQTT streaming: target Akka 2.6 #2118 by @raboof
This milestone contains changes from 19 contributors in the Alpakka community. Thank you all!
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
| ennru |
19 | 3485 | 1287 |
| raboof |
10 | 591 | 537 |
| harshalveera |
10 | 103 | 73 |
| seglo |
5 | 52 | 18 |
| ignasi35 |
3 | 305 | 306 |
| DanieleSassoli |
2 | 705 | 84 |
| nivox |
2 | 604 | 316 |
| michalbogacz |
2 | 108 | 85 |
| sullis |
2 | 2 | 2 |
| aserrallerios |
1 | 1206 | 36 |
| francisdb |
1 | 795 | 92 |
| andreas-schroeder |
1 | 132 | 68 |
| dwickern |
1 | 92 | 12 |
| jcroig |
1 | 79 | 86 |
| dl-mai |
1 | 14 | 1 |
| gabrielreid |
1 | 6 | 2 |
| cheleb |
1 | 3 | 3 |
| touchdown |
1 | 2 | 2 |
| wi101 |
1 | 1 | 1 |
2.0.0-M2
Released 2019-12-17
Notable changes in 2.0.0-M2
- AMQP: flow stages #1921 by @kstrek
- AWS Kinesis: Use AWS SDK v2 #2029 by @regiskuckaertz
- Google-cloud-pub-sub: dedicated connection pool;
withContext#1983 by @btomala
This milestone contains changes from 10 contributors in the Alpakka community. Thank you all!
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
| ennru |
14 | 2073 | 3406 |
| kstrek |
1 | 1610 | 144 |
| an-tex |
1 | 530 | 68 |
 regiskuckaertz |
1 | 460 | 1037 |
| btomala |
1 | 404 | 333 |
| gabrielreid |
1 | 126 | 6 |
| huntc |
1 | 114 | 66 |
| pecorarista |
1 | 4 | 2 |
| sullis |
1 | 1 | 1 |
| ldrygala |
1 | 1 | 1 |
2.0.0-M1
Released 2019-11-08
Notable changes in 2.0.0-M1
- Akka 2.6/2.5 cross-compilation #1988 by @ennru
- AWS S3: Migrate S3 connector to AWS SDK 2 authentication lib #1905 by @2m
- AWS S3: Custom header injection #1947 by @vigoo
- DynamoDb: Update to AWS SDK 2.0 #1725 by @RustedBones
- HDFS: upgrade Cats to 2.0.0 and enable Scala 2.13 #1925
- File: Added flow for creating file ZIP archive #1890 by @michalbogacz
- FTP - Add proxy support to FTP, SFTP, and FTPS connectors #1907 by @mjp426
- IronMq: support Scala 2.13 (and drop 2.11) by akka-http-circe 1.21 to 1.29.1 #1957 by @tg44
- XML: add support for supplying XMLInputFactory configuration #1982 by @jphelp32
- XML: add ability to provide a specific XMLOutputFactory #1945 by @jphelp32
This milestone contains changes from 30 contributors in the Alpakka community. Thank you all!
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
| ennru |
33 | 3335 | 2791 |
| 2m |
19 | 1823 | 560 |
| huntc |
6 | 219 | 99 |
| LGLO |
5 | 524 | 161 |
| jphelp32 |
3 | 222 | 13 |
| cheleb |
3 | 12 | 35 |
| michalbogacz |
2 | 600 | 20 |
| dotbg |
2 | 50 | 9 |
 maxrem |
1 | 560 | 41 |
| vigoo |
1 | 488 | 81 |
 RustedBones |
1 | 395 | 1300 |
| longshorej |
1 | 374 | 217 |
| RomanLebid |
1 | 361 | 81 |
| mjp426 |
1 | 326 | 16 |
| seglo |
1 | 223 | 1 |
| janjaali |
1 | 135 | 58 |
| francisdb |
1 | 76 | 46 |
| Kreinoee |
1 | 55 | 16 |
 WellingR |
1 | 43 | 1 |
| tg44 |
1 | 17 | 21 |
| anzecesar |
1 | 15 | 6 |
| bpiper |
1 | 11 | 9 |
 TimMoore |
1 | 9 | 32 |
| shimamoto |
1 | 8 | 11 |
| DanieleSassoli |
1 | 5 | 5 |
 giena |
1 | 2 | 2 |
 lewisjkl |
1 | 2 | 1 |
| laszlovandenhoek |
1 | 1 | 1 |
| sullis |
1 | 1 | 1 |
| ashwanthkumar |
1 | 1 | 1 |
Changes per module
- AMQP
- Cassandra
- Geode
- Kafka
- Apache Kudu
- Apache Solr
- AvroParquet
- Dynamo DB
- AWS Event Bridge
- AWS Kinesis
- AWS Lambda
- AWS S3
- AWS SNS
- AWS SQS
- Azure Storage Queue
- Comma-separated Values (CSV)
- Couchbase
- Elasticsearch
- File
- FTP
- Google Cloud BigQuery
- Google Cloud Pub/Sub
- Google Cloud Pub/Sub gRPC
- Google FCM
- Google Cloud Storage
- Apache HDFS
- HBase
- InfluxDB
- IronMQ
- JMS
- Json streaming
- MongoDB
- MQTT
- MQTT Streaming
- OrientDB
- Pravega
- Server-sent events (SSE)
- Simple codecs (RecordIO)
- Slick
- Spring Web
- UDP
- Unix Domain Socket
- XML