Skip to content

Releases: evolution-gaming/kafka-flow

v5.1.0

21 Jan 16:48
1445a02
Compare
Choose a tag to compare

Major changes

In order to improve logging when deleting a key, some factory APIs were changed. To preserve binary compatibility, new methods were introduced and the old ones marked as deprecated. The migration should be as straightforward as simply renaming used methods:

  • KeyDatabase#keysOf -> KeyDatabase#toKeysOf
  • Keys#apply -> Keys#of
  • KeysOf#memory -> KeysOf#memory1
  • KeysOf#apply -> KeysOf#of

What's Changed

  • Update testcontainers-scala-cassandra, ... to 0.41.8 by @scala-steward in #667
  • log topic-partition and key in KeyDatabase/Keys logging when deleting a key by @Z1kkurat in #670
  • fix dependency graph GH action by @Z1kkurat in #671

Full Changelog: v5.0.5...v5.1.0

v5.0.5

21 Jan 12:38
27748da
Compare
Choose a tag to compare

What's Changed

  • Switch publishing to evolution-gaming/scala-github-actions by @Z1kkurat in #647
  • Pass SSL related settings to kafka healthcheck consumer by @NikolajsCmihuns in #669

New Contributors

Full Changelog: v5.0.3...v5.0.5

v5.0.3

29 Oct 13:19
14fbc2d
Compare
Choose a tag to compare

What's Changed

Full Changelog: v5.0.2...v5.0.3

v5.0.2

25 Oct 12:37
e6205b3
Compare
Choose a tag to compare
  • Update kafka-journal to 4.1.0

Full Changelog: v5.0.1...v5.0.2

v5.0.1

17 Oct 16:48
9fe7403
Compare
Choose a tag to compare

What's Changed

  • Commit actual latest offsets on partition flow release when commitOnRevoke and flushOnRevoke are enabled by @i-surkov in #641

New Contributors

Full Changelog: v5.0.0...v5.0.1

v5.0.0

08 Oct 16:48
b5dafad
Compare
Choose a tag to compare

Breaking changes

  • dropped APIs marked for deprecation earlier:
    • com.evolutiongaming.kafka.flow.cassandra. CassandraHealthCheckOf. Instead, use com.evolution.kafka.flow.cassandra.CassandraHealthCheckOf
    • com.evolutiongaming.kafka.flow.cassandra. CassandraModule. Instead, use com.evolution.kafka.flow.cassandra.CassandraModule
    • factory methods in com.evolutiongaming.kafka.flow.cassandra.CassandraPersistence that used classes from kafka-journal as parameters: withSchemaF, withSchema and truncate. Use alternatives with the same name taking scassandra.CassandraSession as parameter
    • factory methods in com.evolutiongaming.kafka.flow.journal.CassandraJournals that used classes from kafka-journal as parameters: withSchema and truncate. Use alternatives with the same name taking scassandra.CassandraSession as parameter
    • factory method com.evolutiongaming.kafka.flow.journal.JournalSchema#apply that used classes from kafka-journal as parameters. Use the alternative method JournalSchema#of taking scassandra.CassandraSession as parameter
    • factory methods in com.evolutiongaming.kafka.flow.key.CassandraKeys that used classes from kafka-journal as parameters: two class constructors, withSchema, truncate. Use other primary constructors and method alternatives with the same name taking scassandra classes as parameters
    • factory method com.evolutiongaming.kafka.flow.key.KeySchema#apply that used classes from kafka-journal as parameters. Use the alternative method KeySchema#of taking scassandra.CassandraSession as parameter
    • dropped com.evolutiongaming.kafka.flow.migration helper object that facilitated conversion from kafka-journal FromBytes/ToBytes to skafka FromBytes/ToBytes. Instead, it's advised to implement skafka instances directly without conversions
    • factory methods in com.evolutiongaming.kafka.flow.snapshot.CassandraSnapshots that used classes from kafka-journal as parameters: a class constructor, withSchema, truncate. Use the other primary constructor and method alternatives with the same name taking scassandra classes as parameters
    • com.evolutiongaming.kafka.flow.kafkapersistence#caching taking an instance of ProducerOf. Instead, pass a single instance of Producer explicitly to avoid creating a new producer for each partition
    • com.evolutiongaming.kafka.flow.kafkapersistence.KafkaPersistenceModuleOf#caching taking an instance of ProducerOf. Instead, pass a single instance of Producer explicitly to avoid creating a new producer for each partition

Updated major dependencies:

  • skafka: 16.0.3 -> 17.1.2
  • kafka-journal: 3.4.1 -> 4.0.2

What's Changed

  • Bump skafka and kafka-journal libs, drop deprecates by @Phill101 in #639

Full Changelog: v4.6.0...v5.0.0

v4.6.0

30 Sep 11:46
9049272
Compare
Choose a tag to compare

What's Changed

  • Make keys DDL use LeveledCompactionStrategy by default by @Z1kkurat in #636

Full Changelog: v4.5.1...v4.6.0

v0.14.0

30 Sep 11:53
eaef829
Compare
Choose a tag to compare

What's Changed

  • Make keys DDL use LeveledCompactionStrategy by default [CE2] by @Z1kkurat in #637

Full Changelog: v0.13.2...v0.14.0

v4.5.1

14 Sep 17:06
9c75fae
Compare
Choose a tag to compare

What's Changed

New Contributors

Full Changelog: v4.5.0...v4.5.1

v4.5.0

15 Aug 15:27
8ff0ff9
Compare
Choose a tag to compare

What's Changed

  • Add a flag to enable ignoring errors during additional state persists. by @vilunov in #625

Full Changelog: v4.4.1...v4.5.0