Alpakka 2.0.x

Major version change

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.

Note

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.4+ and Akka 2.5.31+. An exception is MQTT streaming which is available for Akka 2.6 only.

2.0.1

Released 2020-06-09

Notable changes compared to Alpakka 2.0.0

New Connector: AWS EventBridge

AWS Kinesis

See AWS Kinesis for details.

AWS S3

Cassandra

  • Cassandra: Driver 4.6.1 (Remove netty override) #2320 by @chbatey

Comma-separated Values (CSV)

Elasticsearch

File

See changes per module

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.0:

Author Commits Lines added Lines removed
YikSanChan YikSanChan 7 33 54
ennru ennru 2 102 39
KGoodale13 KGoodale13 2 91 0
bpiper bpiper 2 3 3
teroxik teroxik 1 930 1
vaslabs vaslabs 1 140 43
shagoon shagoon 1 77 11
mrooding mrooding 1 56 15
michaeljmarshall michaeljmarshall 1 52 1
iRevive iRevive 1 50 60
sberglann sberglann 1 21 1
yannisf yannisf 1 9 2
tst60 tst60 1 6 1
chbatey chbatey 1 3 9
matsluni matsluni 1 1 1
vigoo 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

See changes per module

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 ennru 120 15290 8988
raboof raboof 14 641 555
2m 2m 10 892 423
seglo seglo 10 430 160
harshalveera harshalveera 10 103 73
cheleb cheleb 6 1658 54
LGLO LGLO 5 524 161
michalbogacz michalbogacz 4 708 105
ignasi35 ignasi35 4 308 308
francisdb francisdb 3 980 171
bpiper bpiper 3 650 180
jphelp32 jphelp32 3 222 13
huntc huntc 3 204 72
sullis sullis 3 3 3
aserrallerios aserrallerios 2 1272 57
DanieleSassoli DanieleSassoli 2 705 84
nivox nivox 2 604 316
btomala btomala 2 470 353
paualarco paualarco 2 311 213
gabrielreid gabrielreid 2 132 8
mpdn mpdn 2 66 58
dotbg dotbg 2 50 9
kstrek kstrek 1 1610 144
r-glyde r-glyde 1 1330 1218
an-tex an-tex 1 530 68
vigoo vigoo 1 488 81
choffmeister choffmeister 1 478 21
Regis Kuckaertz 1 460 1037
longshorej longshorej 1 374 217
RomanLebid RomanLebid 1 361 81
jewertow jewertow 1 333 42
mjp426 mjp426 1 326 16
mdibaiee mdibaiee 1 160 12
janjaali janjaali 1 135 58
andreas-schroeder andreas-schroeder 1 132 68
dwickern dwickern 1 92 12
KGoodale13 KGoodale13 1 81 1
jcroig jcroig 1 79 86
Kreinoee Kreinoee 1 55 16
sturmin sturmin 1 22 1
tg44 tg44 1 17 21
anzecesar anzecesar 1 15 6
dl-mai dl-mai 1 14 1
MrRexZ MrRexZ 1 10 7
Tim Moore 1 9 32
shimamoto shimamoto 1 8 11
pecorarista pecorarista 1 4 2
touchdown touchdown 1 2 2
wi101 wi101 1 1 1
ldrygala ldrygala 1 1 1
ashwanthkumar ashwanthkumar 1 1 1
laszlovandenhoek 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

See changes per module

This release candidate contains changes from 8 contributors in the Alpakka community. Thank you all!

Author Commits Lines added Lines removed
ennru ennru 14 306 210
cheleb cheleb 3 1646 19
choffmeister choffmeister 1 478 21
aserrallerios aserrallerios 1 66 21
btomala btomala 1 66 20
MrRexZ MrRexZ 1 10 7
raboof raboof 1 2 2
paualarco 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.

  • Cassandra: rewrite on top of Java driver 4.5.0 #2182 by @ennru

The MQTT Streaming connector does only support Akka 2.6 now.

  • MQTT streaming: target Akka 2.6 #2118 by @raboof

  • Update Akka to 2.5.30 #2206 by @raboof

  • 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

See changes per module

This release candidate contains changes from 8 contributors in the Alpakka community. Thank you all!

Author Commits Lines added Lines removed
ennru ennru 22 3738 1292
seglo seglo 4 155 141
raboof raboof 3 48 16
bpiper bpiper 2 639 171
francisdb francisdb 2 185 79
jewertow jewertow 1 333 42
mdibaiee mdibaiee 1 160 12
ignasi35 ignasi35 1 3 2

2.0.0-M3

Released 2020-02-20

Notable changes in 2.0.0-M3

See changes per module

This milestone contains changes from 19 contributors in the Alpakka community. Thank you all!

Author Commits Lines added Lines removed
ennru ennru 19 3485 1287
raboof raboof 10 591 537
harshalveera harshalveera 10 103 73
seglo seglo 5 52 18
ignasi35 ignasi35 3 305 306
DanieleSassoli DanieleSassoli 2 705 84
nivox nivox 2 604 316
michalbogacz michalbogacz 2 108 85
sullis sullis 2 2 2
aserrallerios aserrallerios 1 1206 36
francisdb francisdb 1 795 92
andreas-schroeder andreas-schroeder 1 132 68
dwickern dwickern 1 92 12
jcroig jcroig 1 79 86
dl-mai dl-mai 1 14 1
gabrielreid gabrielreid 1 6 2
cheleb cheleb 1 3 3
touchdown touchdown 1 2 2
wi101 wi101 1 1 1

2.0.0-M2

Released 2019-12-17

Notable changes in 2.0.0-M2

See changes per module

This milestone contains changes from 10 contributors in the Alpakka community. Thank you all!

Author Commits Lines added Lines removed
ennru ennru 14 2073 3406
kstrek kstrek 1 1610 144
an-tex an-tex 1 530 68
regiskuckaertz regiskuckaertz 1 460 1037
btomala btomala 1 404 333
gabrielreid gabrielreid 1 126 6
huntc huntc 1 114 66
pecorarista pecorarista 1 4 2
sullis sullis 1 1 1
ldrygala 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 ennru 33 3335 2791
2m 2m 19 1823 560
huntc huntc 6 219 99
LGLO LGLO 5 524 161
jphelp32 jphelp32 3 222 13
cheleb cheleb 3 12 35
michalbogacz michalbogacz 2 600 20
dotbg dotbg 2 50 9
maxrem maxrem 1 560 41
vigoo vigoo 1 488 81
RustedBones RustedBones 1 395 1300
longshorej longshorej 1 374 217
RomanLebid RomanLebid 1 361 81
mjp426 mjp426 1 326 16
seglo seglo 1 223 1
janjaali janjaali 1 135 58
francisdb francisdb 1 76 46
Kreinoee Kreinoee 1 55 16
WellingR WellingR 1 43 1
tg44 tg44 1 17 21
anzecesar anzecesar 1 15 6
bpiper bpiper 1 11 9
TimMoore TimMoore 1 9 32
shimamoto shimamoto 1 8 11
DanieleSassoli DanieleSassoli 1 5 5
giena giena 1 2 2
lewisjkl lewisjkl 1 2 1
laszlovandenhoek laszlovandenhoek 1 1 1
sullis sullis 1 1 1
ashwanthkumar ashwanthkumar 1 1 1

Changes per module

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.