:mega: Alpakka 2.0.2 released!

See the full Release Notes in the Alpakka documentation.

Notable changes compared to 2.0.1

• NEW MODULE: Google bigquery #2252 by @gkatzioura

• Slick/JDBC: Support PreparedStatement use 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

:bow: Credits

Special thanks to the following contributors who helped with this release: @Grandys, @K-Adnan, @aserrallerios, @bgahagan, @cheleb, @ennru, @gkatzioura, @ihostage, @johanandren, @karlssonsimon, @laszlovandenhoek, @mas15, @mpdn, @raboof, @shagoon, @tg44 and @yannisf

See the full Release Notes in the Alpakka documentation.

Changes

• Jackson 2.10.4 (was 2.10.3) #2343 by @ennru

AWS EventBridge

• Docs: AWS Eventbridge link #2337 by @ennru
• AWS EventBridge Support #2061 by @teroxik

AWS Lambda

• Update AwsSpiAkkaHttpVersion to 0.0.9 #2328 by @matsluni

AWS Kinesis

• Kinesis: Construction safe API #2331 by @vaslabs
• Update AwsSpiAkkaHttpVersion to 0.0.9 #2328 by @matsluni
• Kinesis: code layout #2300 by @YikSanChan
• Kinesis: Avoid Any in KinesisSchedulerSourceStage #2297 by @YikSanChan
• Kinesis: Small cleanup #2299 by @YikSanChan
• [kinesis] Get rid of unnecessary broadcast-zip #2302 by @YikSanChan
• Kinesis: Give the callback a more meaningful name #2298 by @YikSanChan
• Fix typo in comment #2301 by @YikSanChan
• Kinesis: Fix arrow #2303 by @YikSanChan

AWS S3

• AWS S3: parse error replies #2341 by @ennru
• S3: URI pattern to support all regions #2336 by @iRevive
• Fix intermittent issues with Wiremock connection reset simulation #2319 by @bpiper
• S3: Add some backoff delay to multipart upload retries for tests #2282 by @bpiper

AWS SNS

• Update AwsSpiAkkaHttpVersion to 0.0.9 #2328 by @matsluni

AWS SQS

• Update AwsSpiAkkaHttpVersion to 0.0.9 #2328 by @matsluni

Cassandra

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

Comma-separated Values (CSV)

• CSV: handle UTF-8 BOM correctly #2311 by @tst60

Couchbase

• Docs: fix Couchbase link to DiscoverySupport API #2340 by @ennru

Dynamo DB

• Removed obsolete reference config for Alpakka DynamoDB #2333 by @vigoo
• Update AwsSpiAkkaHttpVersion to 0.0.9 #2328 by @matsluni

Elasticsearch

• Elasticsearch: Support the routing parameter #2272 by @yannisf
• ElasticsearchSource: Clear Scroll On Exhaustion or Completion #2330 by @michaeljmarshall
• Elasticsearch: Log indexing errors #2317 by @KGoodale13
• [elasticsearch] Support allow_explicit_index: false #2326 by @mrooding
• [Elasticsearch] Add createBulk factory methods #2306 by @KGoodale13

File

• Allow LogRotatorSink be a Sink[T] instead of Sink[ByteString] #2323 by @shagoon
• file/tar: Allow space as terminal character in tar header #2325 by @sberglann

See the full Release Notes in the Alpakka documentation.

See the full Release Notes in the Alpakka documentation.

See the full Release Notes in the Alpakka documentation.

See the full Release Notes in the Alpakka documentation.

See the full Release Notes in the Alpakka documentation.

See the full Release Notes in the Alpakka documentation.

See the full Release Notes in the Alpakka documentation.

See the full Release Notes in the Alpakka documentation.

Changes

• Release notes for 1.1.1 #1867 by @ennru
• Upgrade Jackson Databind and test dependencies #1859 by @ennru
• Docs: move JMS examples to alpakka-samples #1866 by @ennru
• Ftp: migrates RotateLogsToFtp to Java #1479 #1846 by @fagossa
• Docs: fix links to 1.0.x release notes #1828 by @ennru
• mockito 3.0.0 #1823 by @sullis
• Minor doc fixes #1813 by @ennru
• Canonical URL fix #1808 by @ennru

Infrastructure

• Scalafmt: update plugin to 2.0.3 #1871 by @ennru
• Autolabeler config #1870 by @ennru
• Scaladoc: exclude jwt-core 3.0.1 during unidoc #1869 by @ennru
• Mima: don't check reference connector, as it is not published #1861 by @ennru
• Mima: generally allow changes to the impl-package #1860 by @ennru
• Build all connectors when building in nightly #1851 by @2m
• Update to Alpakka Kafka #1841 by @2m
• Update to Akka 2.6.0-M5 #1842 by @2m
• Update to the latest Akka 2.6-M4 #1818 by @2m
• Move out Elasticsearch example to Alpakka-samples #1819 by @ennru
• Use JDK 11 when running nightly #1809 by @2m

Apache Solr

• Solr: deleteByQuery with routing field #1822 by @newca12

Apache HDFS

• HDFS: fix target file overwrite #1834 by @markarasev

Comma-separated Values (CSV)

• CSV: accept quotes ending mid-column #1858 by @ennru

Dynamo DB

• DynamoDB: Add TransactionCanceledException #1863 by @pulltab

Elasticsearch

• Elasticsearch: store JSON strings #1862 by @ennru

FTP

• FTP: Mkdir #1816 by @MarcinAman
• Add imports to Ftp settings sample, actually run listFiles #1812 by @raboof

Google Cloud Storage

• Enable MiMa on Google Cloud Storage and InfluxDb #1814 by @2m

InfluxDB

• Enable MiMa on Google Cloud Storage and InfluxDb #1814 by @2m

JMS

• JMS transactions: fail stream or log on ack timeouts #1857 by @ennru

MQTT Streaming

• Start deferred behaviors #1865 by @2m
• Treat ConsumeFailed as a problem #1852 by @huntc
• Failure to attain QoS is not bad #1845 by @huntc
• Make typed/untyped MqttFlowSpec independent #1849 by @2m
• Spawn MQTT connector actors as system actors #1848 by @2m
• mqtt-streaming: Partially revert #1818 #1832 by @longshorej
• Complete promise from the locally submitted ack #1807 by @huntc
• Update to the latest Akka 2.6-M4 #1818 by @2m