Akka Projections 1.2.4

Changes

• Fix test of stopping ProjectionBehavior #660 by @patriknw
• Always stop running projection when ProjectionBehavior is stopped, #586 #659 by @patriknw
• update sbt to 1.6.2 #645 by @octonato
• improved retryAndFail tests #646 by @octonato
• mysql-connector-java 8.0.28 (was 8.0.27) #636 by @scala-steward
• sbt-java-formatter 0.7.0 (was 0.6.1) #629 by @scala-steward
• hibernate-core 5.4.33 (was 5.4.32.Final) #630 by @scala-steward
• postgresql 42.3.1 (was 42.2.24) #631 by @scala-steward
• paradox-theme-akka, ... 0.42 (was 0.40) #634 by @scala-steward
• sbt-header 5.6.5 (was 5.6.0) #635 by @scala-steward
• Update to sbt 1.5.8 #624 by @jrudolph
• Store offset for failed skipped envelope #640 by @patriknw
• update copyright year to 2022 #625 by @octonato
• mysql-connector-java 8.0.27 (was 8.0.25) #604 by @scala-steward
• use upstream release-drafter #621 by @octonato
• scala-library 2.12.15 (was 2.12.13) #598 by @scala-steward
• postgresql 42.2.24 (was 42.2.20) #597 by @scala-steward
• sbt-java-formatter 0.6.1 (was 0.6.0) #590 by @scala-steward
• sbt-git 1.0.2 (was 1.0.1) #595 by @scala-steward
• paradox-theme-akka, ... 0.40 (was 0.39) #615 by @scala-steward
• Remove fail fast check in EventsBySlicesSourceProvider #620 by @patriknw

commits  added  removed
      4    225      204 Renato Cavalcanti
      4    138       33 Patrik Nordwall
      1      1        1 Johannes Rudolph

Akka Projections 1.2.3

Changes

• Akka 2.6.18, and logback 1.2.9 #617 by @patriknw
• Improved how to publish docs to Gustav #611 by @octonato
• Update to sbt 1.5.6 #613 by @jrudolph
• minor fix in documentation for relational database projections #612 by @aldenml
• fix github.base_url #610 by @octonato
• Add slices to EventSourcedProvider and DurableStateSourceProvider #609 by @patriknw
• Open up saveOffsetAndReport #600 by @patriknw
• feat: link to video in Getting Started Guide #592 by @ennru
• paradox-theme-akka, ... 0.39 (was 0.38) #580 by @scala-steward
• fix: exclude jackson from scala steward #575 by @octonato
• Remove Whitesource #585 by @patriknw

commits  added  removed
      3    592       50 Patrik Nordwall
      3      4        1 Renato Cavalcanti
      1      3        3 Alden Torres
      1      5        0 Enno Runne
      1      1        1 Scala Steward
      1      1        1 Johannes Rudolph

Akka Projections 1.2.2

Changes

• Durable state projection #564 by @RayRoestenburg
• fix: remove silencer plugin #576 by @octonato
• hibernate-core 5.4.32.Final (was 5.4.31.Final) #569 by @scala-steward
• sbt-git 1.0.1 (was 1.0.0) #568 by @scala-steward
• akka-persistence-jdbc 5.0.1 (was 5.0.0) #566 by @scala-steward
• mysql-connector-java 8.0.25 (was 8.0.23) #560 by @scala-steward
• hibernate-core 5.4.31.Final (was 5.4.30.Final) #561 by @scala-steward
• postgresql 42.2.20 (was 42.2.19) #562 by @scala-steward

Credits

commits  added  removed
      1    385        4 Raymond Roestenburg
      1      7       15 Renato Cavalcanti

Akka Projections 1.2.1

Changes

• Clarify actor lifecycle #551 by @patriknw
• add CiReleasePlugin to requires in Common #552 by @patriknw
• Use Java functional interface in Java DSL of JdbcHandler #554 by @ihostage
• Fix Java pause/resume docs example to finish with resume #557 #558 by @ihostage

Credits

commits  added  removed
      2     29       17 Sergey Morgunov
      2      4        1 Patrik Nordwall

Akka Projections 1.2.0

Changes

• Pause and resume projection, #25 #538 by @patriknw
• Fix case of table names problem with OracleDialect and default settings #543 by @ihostage
• Akka 2.6.14 and Jackson 2.11.4 #541 by @patriknw
• Rename createOffsetTableIfNotExists and dropOffsetTableIfExists #546 by @patriknw
• Configurable path of dispatcher for JDBC projections #542 by @ihostage
• Retry management operations if timeout, #531 #532 by @patriknw

This version requires creating the new projection_management table, which is used for storing the pause/resume state of the projections. This table is required even if the new pause/resume functionality isn't used. For rolling update you can create the table while the 1.1.0 version is still running. No other database maintenance is required since all existing database elements are compatible.

See schema definitions:

• JDBC: https://doc.akka.io/docs/akka-projection/current/jdbc.html#schema
• Slick: https://doc.akka.io/docs/akka-projection/current/slick.html#schema
• Cassandra: https://doc.akka.io/docs/akka-projection/current/cassandra.html#schema

Credits

commits  added  removed
      5    486      140 Renato Cavalcanti
      4   3207      137 Patrik Nordwall
      2     39       19 Sergey Morgunov
      1      1        1 Sean Glover

Lightbend employs the Akka core team. If you're looking to take your Akka systems to the next level, let's set up a time to discuss our enterprise-grade expert support, self-paced education courses, and technology enhancements that help you manage, monitor and secure your Akka systems - from development to production.

Akka Projections 1.1.0

We're happy to announce the release of Akka Projections 1.1.0.

Changes since 1.0.0

This release includes some changes on for the JDBC and Slick schema for PostgresSQL and H2 databases. The previous version was generating the schema using quoted and uppercased table and column names.

Although, it doesn't make any difference on how projections work, it is inconvennient to create schemas as such because it force queries to always use quoted and uppercased statements, eg: select * from "AKKA_PROJECTION_OFFSET_STORE".

The PostgresSQL schema defaults now to unquoted lowercase, which allows queries as in select * from akka_projection_offset_store.

H2 requires the usage of quotes, but are now using lowercase, allowing queries as in select * from "akka_projection_offset_store".

There is a backward compatibility mode in case you prefer to stay on the old schema. See migration section below.

In addtition to that, and in the same spirit of improving the develop expericence, JdbcProjection and SlickProjection now include a dropOffsetTableIfExists to drop the database. Useful for testing purposes.

Migration

As of version 1.1.0, the schema for PostgreSQL and H2 databases has changed. It now defaults to lowercase table and column names.
If you have a schema in production, we recommend applying an ALTER table script to change it accordingly.

Alternatively, if you prefer to keep using uppercase quoted names you can fallback to the legacy format.

Users of akka-projection-jdbc can revert to legacy format with the following configuration settings:

akka.projection.jdbc.offset-store {
  table = "AKKA_PROJECTION_OFFSET_STORE"
  use-lowercase-schema = false
}

Users of akka-projection-slick can revert to legacy format with the following configuration settings:

akka.projection.slick.offset-store {
  table = "AKKA_PROJECTION_OFFSET_STORE"
  use-lowercase-schema = false
}

The full documentation can be found at https://doc.akka.io/docs/akka-projection/current/.

API stability

We consider the API stable even though we’re still not making any bincompat promise and you should consider all the public API as ApiMayChange. It might be changed based on feedback from initial usage.

Changes

• Table and column names in lowercase #499 by @octonato
• fix strange config syntax for jdbc and slick #502 by @patriknw
• Update headers #500 by @octonato
• Include 'if not exists' when creating index #490 by @octonato

Updates

• mysql-connector-java 8.0.22 (was 8.0.21) #473 by @scala-steward
• jackson-databind 2.10.5.1 (was 2.10.5) #495 by @scala-steward
• Alpakka Kafka 2.0.6 #498 by @seglo
• sbt 1.4.6 (was 1.4.5) #506 by @scala-steward
• paradox-theme-akka, ... 0.36 (was 0.35) #496 by @scala-steward
• hibernate-core 5.4.26.Final (was 5.4.23.Final) #497 by @scala-steward
• sbt 1.4.5 (was 1.4.0) #485 by @scala-steward
• Bump alpakka-kafka to fix cp-kafka image changes #492 by @seglo
• sbt-site 1.4.1 (was 1.4.0) #482 by @scala-steward
• sbt-bintray 0.6.1 (was 0.5.6) #483 by @scala-steward
• hibernate-core 5.4.23.Final (was 5.4.21.Final) #484 by @scala-steward
• sbt-mima-plugin 0.8.1 (was 0.8.0) #481 by @scala-steward
• junit 4.13.1 (was 4.13) #472 by @scala-steward
• postgresql 42.2.18 (was 42.2.16) #475 by @scala-steward
• sbt 1.4.0 (was 1.3.13) #476 by @scala-steward
• Akka 2.6.10, and use akka.stream.RestartSettings, #466 #467 by @patriknw
• Update akka-persistence-cassandra to 1.0.3 #451 by @scala-steward
• Alpakka Cassandra 2.0.2 #456 by @scala-steward
• Alpakka 2.0.2 (Netty override) #457 by @ennru

Documentation

• Add warning about schema change #507 by @octonato
• warn about too many tags for Cassandra #469 by @patriknw
• clarify that Slick module is community-driven #464 by @patriknw
• clarify tagging and hide EventGeneratorApp, #449 #463 by @patriknw
• links to platform guide #487 by @patriknw
• update use case images #468 by @patriknw
• Change readiness level to Supported #453 by @ennru
• Akka Projections plural #452 by @patriknw

Build

• Enable header check for it tests #503 by @octonato
• Adds release drafter #478 by @ignasi35
• Assert Option where assertion not retried #461 by @seglo
• Wait for onError stream event #460 by @seglo
• MiMa configuration #450 by @octonato
• added scala steward config #446 by @octonato
• improve test resume in KafkaToSlickIntegrationSpec #442 by @patriknw

Contributing

Feedback, bug reports and feature requests are welcome as issues in akka-projection/issues.

Credits

For this release we had the help of 5 committers – thank you all very much!

commits   added  removed
      9     184      111 Patrik Nordwall
      7     676      381 Renato Cavalcanti
      4     139       73 Sean Glover
      2      37        7 Enno
      1      27        0 Ignasi Marimon-Clos

The Akka core team is employed by Lightbend. If you're looking to take your Akka systems to the next level, let's set up a time to discuss our enterprise-grade expert support, self-paced education courses, and technology enhancements that help you manage, monitor and secure your Akka systems - from development to production.

Happy hakking!

– The Akka Team

Release 1.0.0 - GA

We're proud to announce the release of Akka Projections 1.0.

The full documentation can be found at https://doc.akka.io/docs/akka-projection/current/.

Supported by Lightbend

Starting at Akka Projections 1.0.0, this module is now officially Supported as part of a Lightbend Subscription.

API stability

We consider the API stable even though we’re still not making any bincompat promise and you should consider all the public API as ApiMayChange. It might be changed based on feedback from initial usage.

Migrating from previous Release Candidates

If you have been using a Release Candidate with JDBC or Slick, there is a small change in the offset store table. The OFFSET column has been renamed to CURRENT_OFFSET. Make sure to rename it in your existing schema before upgrading to version 1.0.0.

Contributing

Feedback, bug reports and feature requests are welcome as issues in akka-projection/issues.

Credits

For this release we had the help of 9 committers – thank you all very much!

commits   added  removed
    128   16517     6609  Renato Cavalcanti
     88   18580     2529  Patrik Nordwall
     43    7784     3363  Sean Glover
     28    3278      661  Ignasi Marimon-Clos
     11     339       45  Enno Runne
      1       5        5  Evan Chan
      1      11       11  Christopher Batey
      1      39       34  Claudio Scandura
      1       1        1  Johan Andrén

The Akka core team is employed by Lightbend. If you're looking to take your Akka systems to the next level, let's set up a time to discuss our enterprise-grade expert support, self-paced education courses, and technology enhancements that help you manage, monitor and secure your Akka systems - from development to production.

Happy hakking!

– The Akka Team

v1.0.0-RC3

We're happy to announce the latest release candidate of Akka Projections, version 1.0.0-RC3. If no serious bug is reported this RC3 will become 1.0.0 GA next week.

We consider the API stable even though we’re still not making any bincompat promise and you should consider all the public API as ApiMayChange. It might be changed based on feedback from initial usage.

Feedback, bug reports and feature requests are welcome as issues in akka-projection/issues.

Highlights of the release:

• Improved Getting Started Guide, including examples in both Java and Scala.
• Fix off by one problem in KafkaSourceProvider, #382

The documentation can be found at https://doc.akka.io/docs/akka-projection/current/.

A total of 22 issues were closed in this release. The complete list can be found on the 1.0.0-RC3 milestone on github.

Credits

For this release we had the help of 4 committers – thank you all very much!

commits   added  removed
     12    3235     1826 Sean Glover
      7     230      137 Patrik Nordwall
      1       1        1 Johan Andrén
      1      30       12 Renato Cavalcanti

The Akka core team is employed by Lightbend. If you're looking to take your Akka systems to the next level, let's set up a time to discuss our enterprise-grade expert support, self-paced education courses, and technology enhancements that help you manage, monitor and secure your Akka systems - from development to production.

Happy hakking!

– The Akka Team

v1.0.0-RC2

Please ignore this release. Some artifacts were not published correctly.

v1.0.0-RC1

We're happy to release the first release candidate of Akka Projections, version 1.0.0-RC1. If no serious bug is reported this RC1 will become GA.

We consider the API stable even though we’re still not making any bincompat promise and you should consider all the public API as ApiMayChange. It might be changed based on feedback from initial usage.

Feedback, bug reports and feature requests are welcome as issues in akka-projection/issues.

Highlights of the release:

• Unified schemas for JDBC and Slick
• Support blocking in JdbcHandler start/stop
• StatusObserver fine grained callbacks
• Converged StatusObserver semantics to Telemetry: progress reports iff offset has been committed
• Fix: ClassCastException after restart when using Kafka source
• Fix: MetadataClientAdapter actor already terminated message when restarting a Projection
• Fix: JdbcSettings fails when using variable substitution
• Many documentation improvements

The documentation can be found at https://doc.akka.io/docs/akka-projection/current/.

A total of 45 issues were closed in this release. The complete list can be found on the 1.0.0-RC1 milestone on github.

Credits

For this release we had the help of 4 committers – thank you all very much!

commits  added  removed
     24   1724     1102 Renato Cavalcanti
     24   1634      518 Ignasi Marimon-Clos
      8   1737      624 Sean Glover
      1      1        1 Patrik Nordwall

The Akka core team is employed by Lightbend. If you're looking to take your Akka systems to the next level, let's set up a time to discuss our enterprise-grade expert support, self-paced education courses, and technology enhancements that help you manage, monitor and secure your Akka systems - from development to production.

Happy hakking!

– The Akka Team